反压(backpressure)是实时计算应用开发中,特别是流式计算中,十分常见的问题。反压意味着数据管道中某个节点成为瓶颈,处理速率跟不上上游发送数据的速率,而需要对上游进行限速。由于实时计算应用
要解决反压首先要做的是定位到造成反压的节点,这主要有两种办法:通过 Flink Web UI 自带的反压监控面板;通过 Flink Task Metrics。前者比较容易上手,适合简单分析,后者则提供