我使用的是vm,我的集群由3个taskmanagers组成,主控也是jobmanager和taskmanager(4个taskmanagers和一个jobmanager),大约12gbram和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)上运行
暂无答案!
目前还没有任何答案,快来回答吧!