Я использую ВМ, и мой кластер состоит из 3 менеджеров задач, а мастер также является менеджером работ и менеджером задач (4 менеджера задач и один менеджер работ), около 12 ГБ оперативной памяти и 6 процессоров, и использую версию 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,
Я обнаружил, что задание все еще выполняется на канале данных (сбор)