Контрольно-пропускные пункты Флинка сохранены ⇐ 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-сохранено
Разве это не работает в моем случае? если да, то чего мне не хватает?
Или я ошибаюсь?
Я развернул диспетчер задач и диспетчер заданий в контейнере 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-сохранено
Разве это не работает в моем случае? если да, то чего мне не хватает?
Или я ошибаюсь?
