19.flink task slot taskManage

flink并行度设置

摘要

摘要

读者需了解flink任务划分的原因是什么？若不清楚，则对此篇文章而言毫无价值。

1.parallelism.default:

我觉得还是英文说的清楚,就不翻译了。
（默认值：1）。当设置环境中无并发任务运行时,将此值设为NumTaskManagers * NumSlotsPerTaskManager会使系统利用所有可用执行资源来执行该程序。
注：为整个作业指定并行策略可通过调用ExecutionEnvironment上的setParallelism(int parallelism)方法实现,也可通过在Flink命令行前端使用-p参数完成。对于单个转换,可通过操作对象上的setParallelism(int parallelism)方法来指定并行策略。有关并行性的详细信息,请参阅《Parallel Execution》一节。

---

---

英文解读：默认全局线程池大小设置为 1，并行性默认（parallelism.default）指的是整个Flink进程使用的线程池大小。
并行性默认参数的设置方法

env.setParallelism(int parallelism)

/flink-1.13.6/bin/flink run … -Dparallelism.defaul