Я безуспешно пытался перезапустить свой Apache Flink с предыдущей контрольной точки. Я загрузил код в GitHub, вот основной класс:
https://github.com/edu05/wordcount/blob/restart/src/main/java/edu/streaming/AppWithKafka.java
Это простая программа для подсчета слов, только я бы хотела, чтобы программа продолжила подсчет, уже рассчитанный после перезапуска.
Я прочитал документы и попробовал несколько вещей, но, должно быть, чего-то не хватает, может кто-то помочь?
Кроме того: конечной целью является вывод результатов программы wordcount в сжатую тему kafka. Как бы мне загрузить загрузку состояния приложения, сначала используя сжатую тему, которая в данном случае служит одновременно а контрольно-пропускной механизм программы?
Большое спасибо