apache-flink - 增加并行度对吞吐量的影响

Question

我先用 Parallelism 1 运行工作，然后用 Parallelism 3 运行。在 Parallelism=1 的情况下，kafka 源以每秒约 500 条记录的速度读取记录。当 Parallelism=3 时，吞吐量在三个并行度之间分配，每个并行度大约每秒读取约 150 条记录。请注意，源以更高的速度发布记录（每秒约 1000 条记录）。

这是预期的吗？我会想象吞吐量会随着并行性而增加，但它保持不变。我检查了Backpressure源上的状态，它是High.

截图供参考：

并行度1：

并行度 3：

标签： apache-flinkflink-streaming