天天看點

Flink的反壓和Strom有哪些不同?

Storm 是通過監控 Bolt 中的接收隊列負載情況,如果超過高水位值就會将反壓資訊寫到 Zookeeper ,Zookeeper 上的 watch 會通知該拓撲的所有 Worker 都進入反壓狀态,最後 Spout 停止發送 tuple。Flink中的反壓使用了高效有界的分布式阻塞隊列,下遊消費變慢會導緻發送端阻塞。二者最大的差別是Flink是逐級反壓,而Storm是直接從源頭降速。

繼續閱讀