Hi,主要是pull模型:下游主动拉取上游的数据。可以在下游的消费能力达到极限时,通过反压机制,让上游减少生产的数据。
-- Best! Xuyang 在 2022-09-09 19:04:27,"郑 致远" <zehongzheng2...@hotmail.com> 写道: >各位大佬好 >请教下, >flink 的数据传输,是上游算子推给下游, 还是下游算子拉取上游, 这么设计的考虑是啥呢?
Hi,主要是pull模型:下游主动拉取上游的数据。可以在下游的消费能力达到极限时,通过反压机制,让上游减少生产的数据。
-- Best! Xuyang 在 2022-09-09 19:04:27,"郑 致远" <zehongzheng2...@hotmail.com> 写道: >各位大佬好 >请教下, >flink 的数据传输,是上游算子推给下游, 还是下游算子拉取上游, 这么设计的考虑是啥呢?