Я не сконфигурировал каталог контрольных точек в 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
Я думал, что эти две директории - одно и то же, потому что они связаны с хранилищем состояний.
Могу ли я установить эти две директории с одинаковой директорией?