我会在一台机器上运行我的flink应用程序,我想为这个应用程序指定20个内核。实际上,我想做的,以spark为例,是:
spark-submit --master local[20]
我会问我如何提交我的Flink申请在一台机器作为Spark做。
vm0i2vca1#
一个选项是将并行数设置为cli命令./bin/flink run-p10../examples/wordcount-java.jar
1条答案
按热度按时间vm0i2vca1#
一个选项是将并行数设置为cli命令
./bin/flink run-p10../examples/wordcount-java.jar