flink 如何支持本地模式?



我会在一台机器上运行我的 flink 应用程序,我想为这个应用程序指定 20 个内核。实际上,我想做的,以火花为例,是:

spark-submit --master local[20]

我会问我如何像 Spark 一样在一台机器上提交我的 flink 应用程序。

一种选择是将并行度设置为Cli命令

./bin/flink run -p 10 ../examples/WordCount-java.jar

相关内容

  • 没有找到相关文章