CheckpointConfig говорит, что нужно сохранять контрольные точки periodi c, но каталог контрольных точек не настроен - PullRequest
0 голосов
/ 23 апреля 2020

Я не сконфигурировал каталог контрольных точек в flink-conf.yaml в Fink, используя state.checkpoints.dir, но я указал путь к бэкэнду состояния в конструкторе FsStateBackend

env.setStateBackend(new FsStateBackend(Common.getFsBackendPath()))

Я бы спросил, в чем разница между этими двумя директориями,

1. state.checkpoints.dir
2. state backend path of FsStateBackend's constructor

Я думал, что эти две директории - одно и то же, потому что они связаны с хранилищем состояний.

Могу ли я установить эти две директории с одинаковой директорией?

...