Я запускаю задание в среде flink, но задание, все еще работающее на этапе сбора данных (без сбора), не отображается в терминале или в пользовательском интерфейсе flink. Я использовал эту команду для запуска задания:
./bin/flink run -p 4 -q examples/gelly/flink-gelly-examples_*.jar --algorithm PageRank --input CSV --type integer --simplify directed --input_filename WikiTalk.txt --input_field_delimiter $'\t' --output print
в журнале есть выходные данные, но в веб-интерфейсе отправленные байты стали равны 0, и после этого прогресс не отображается, так что
отображается в столбце отправленных байтов в последней строке
Я упомянул некоторые скриншоты для веб-интерфейса
часть данных журнала в JobManager, и кажется, что работает канал данных без прогресса в течение времени
конфигурация менеджера заданий
конфигурация менеджеров задач
все это на flink-1.4.2 и, если я использовал версию, flink 1.7 .2 Я получил исключение, которое относится к ошибкам в конфигурациях.