开发者社区> 问答> 正文

Flink是怎样处理反压的呀?

Flink是怎样处理反压的呀?

展开
收起
游客5ixw6pdymb5xs 2021-12-08 13:36:54 417 0
1 条回答
写回答
取消 提交回答
  • Flink 内部是基于 producer-consumer 模型来进行消息传递的,Flink的反压设计也是基于这个模型。Flink 使用了高效有界的分布式阻塞队列,就像 Java 通用的阻塞队列(BlockingQueue)一样。下游消费者消费变慢,上游就会受到阻塞。

    2021-12-08 13:37:27
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Flink CDC Meetup PPT - 龚中强 立即下载
Flink CDC Meetup PPT - 王赫 立即下载
Flink CDC Meetup PPT - 覃立辉 立即下载