Flink使用pipeline.operator-chaining定位问题

问题现象

Flink运行过程中会将算子进行串联形成一个task来降低网络等开销，但是在遇到背压、数据不准确等情况时，因为多个算子串联在一起，无法快速定位是哪个算子有问题。

解决方法

通过将“pipeline.operator-chaining”参数值设置为“false”，把算子链打散来观察是哪个算子有问题。

pipeline.operator-chaining=false

案例说明

以一个作业为例，作业的第二个task已经busy，但是因为算子都串联在一起，无法判断是哪个算子有问题。

通过pipeline.operator-chaining=false将算子链打散，就能看到是map算子有问题，从而进一步确认问题原因。