Flink如何实现反压？
发布时间:2022-09-02 16:59:00
发布人:wjy
Flink 内部是基于producer-consumer模型来进行消息传递的， Flink的反压设计 也是基于这个模型。
Flink 使用了高效有界的分布式阻塞队列， 就像Java通用 的阻塞队列（ BlockingQueue ） 一样。
下游消费者消费变慢， 上游就会受到阻塞。
下一篇Flink反压机制？
