Flink -转发给DiscardingSink的操作符和不发送的操作符有什么区别？

Question

我在Flink中有如下数据流：

源->算子-> DiscardingSink

那和没有水槽的有什么区别吗？

源->算子->

从我的测试中，它似乎运行相同，虽然在第一种情况下，我看到操作符和接收器是链接的，没有从接收器发送记录。在第二种情况下，我可以看到记录被转发了，但它们无处可去。

据我所知，操作员将用记录填充它的传出网络缓冲区，我预计在某个时候会看到反压力，但这种情况不会发生，那么我在这里应该期望的语义是什么呢？

Answer 1

背压只在洗牌时出现。

您的示例都是链式或正向连接，没有混洗连接。

也许您可以将操作符的并发性设置为不同，这样就会发生洗牌连接。