如何在Flink状态下改变算子的最大并行性

Question

我想改变Flink作业的最大并行性，当前状态下的最大并行度是128，我想将它更改为256，我通过状态API更改了键状态下的最大并行性，但是我的接收器操作符的最大并行度仍然是128，因为没有定义状态描述符，所以我无法从状态描述符的名称中获取状态数据，所以我不能更改it.How可以更改它。

Answer 1

最大并行性是您通过Savepoint.create(StateBackend stateBackend, int maxParallelism)创建的新保存点的一个属性。单个操作符没有它们自己的最大并行性。

如果接收器是有状态的，那么它将有一个状态描述符，您可以迁移它的状态。如果不是有状态的，就没什么好担心的了。