反压笔记

  定位反压节点 要解决反压首先要做的是定位到造成反压的节点，这主要有两种办法 : 1. 通过 Flink Web UI 自带的反压监控面板； 2. 通过 Flink Task Metrics。   如果处于反压状态，那么有两种可能性： １. 该节点的发送速率跟不上它的产生数据速率。这一般会发生在一条输入多条 输出的 Operator（比如 flatmap）。 ２. 下游的节点接受速率较慢，通过反

>>阅读原文<<