开发者社区> 问答> 正文

Flink的反压和Strom有哪些不同呢?

Flink的反压和Strom有哪些不同呢?

展开
收起
游客5ixw6pdymb5xs 2021-12-08 13:37:53 456 0
1 条回答
写回答
取消 提交回答
  • Storm 是通过监控 Bolt 中的接收队列负载情况,如果超过高水位值就会将反压信息写到 Zookeeper ,Zookeeper 上的 watch 会通知该拓扑的所有 Worker 都进入反压状态,最后 Spout 停止发送 tuple。

    Flink中的反压使用了高效有界的分布式阻塞队列,下游消费变慢会导致发送端阻塞。

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

相关电子书

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