Контрольно-пропускные пункты Флинка сохранены ⇐ JAVA

[Anonymous]

Я развернул диспетчер задач и диспетчер заданий в контейнере Docker и настроил следующие параметры в flink-conf.yaml.

state.checkpoints.dir: file:///tmp/flink/checkpoints state.storage.fs.memory-threshold: 0 state.backend.type: RocksDB state.backend.incremental: правда state.checkpoints.num-сохранено: 100 Когда я проверил каталог tmp/flink/checkpoints диспетчера задач, там было много каталогов chk-X, хотя я настроил там только 100. Но в каталоге менеджера заданий tmp/flink/checkpoints есть только один chk-X (каталог последней контрольной точки).

Тогда какой в ​​этом смысл

state.checkpoints.num-сохранено

Разве это не работает в моем случае? если да, то чего мне не хватает?

Или я ошибаюсь?