flink-streaming - 流拆分中的 Flink 背压

Question

背景

我们有以下 Flink 执行计划：

Operator 2：

1. 并行度低。每个键都有许多记录。
2. 根本没有记录。

问题

我们看到背压Operator 1。

问题

尽管它根本没有记录，是否有可能Operator 2导致背压？Operator 1

标签： flink-streaming