我会在一台机器上运行我的 flink 应用程序,我想为这个应用程序指定 20 个内核。实际上,我想做的,以火花为例,是:
spark-submit --master local[20]
我会问我如何像 Spark 一样在一台机器上提交我的 flink 应用程序。
一种选择是将并行度设置为Cli命令
./bin/flink run -p 10 ../examples/WordCount-java.jar