我正在使用 VM,我的集群由 3 个任务管理器组成,主服务器也是作业管理器和任务管理器(4 个任务管理器和一个作业管理器),大约 12 GB 内存和 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,
我发现作业仍在 datasink(collect) 上运行