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