Не удается получить контрольную точку для загрузки в Flink

Question

Я бы хотел, чтобы последняя контрольная точка была загружена во Flink, но это не так. Я написал приложение для подсчета слов, которое должно возобновить подсчет с того места, на котором оно остановилось после перезапуска. Я запускаю его из своей среды IDE, поэтому я не запускаю кластер Flink.

Вот код, который я написал https://github.com/edu05/wordcount/tree/simple Который вдохновлен примером, предоставленным создателями Flink о контрольных точках ... https://github.com/streaming-with-flink/examples-scala

Чего мне не хватает? Как я могу также избежать перепечатки некоторых слов? Я не вижу много участников в Stackoverflow на Apache Flink, есть ли другой более подходящий форум?

Answer 1

Контрольные точки по умолчанию не сохраняются и используются только для возобновления работы после сбоев.

Если вам нужно запустить работу с сохраненной контрольной точки, вы должны сделать это вручную, так же как с точки сохранения, выполнив следующие действия.путь:

$ bin/flink run -s :checkpointMetaDataPath [:runArgs]