StreamExecutionEnvironment.setMaxParallelism
中的javadoc引用如下:
最大并行度指定动态扩展的上限。
这里指的是哪种动态扩展?我找不到运算符自动缩放的实证证据:无论有多少个空闲插槽,maxParallelism
有多大,以及有多少个逻辑分区,实际并行度(根据Web UI)总是通过asetParallelism
设置的。
此外,根据这篇https://dev59.com/iqDia4cB1Zd3GeqPMfyT#43493109中被接受且从未受到挑战的回答,Flink中不存在动态缩放。
那么有吗?还是javadoc误导了(或者“动态”在这里的含义是什么?)?如果没有,有计划添加此功能吗?