如何发现Flink是否存在反压？

1、Flink Web UI： Flink提供了一个Web界面，可以查看任务链的状态和缓冲区大小。如果某个算子的缓冲区大小过大，可能会发生反压。
2、Flink Metrics，此方式一般结合Prometh和Grafana查看，可以更清晰的查看到更详细的内容如：uptime(作业持续运行的时间),fullRestarts（作业重启的次数）、numRecordsIn，numBytesInLocal等相关指标来关注作业每天处理的消息数目及高峰时间段的流量，通过关注这些指标可以观察作业的流量表现是否正常
3、日志记录： Flink在发生反压时，会记录相关的日志信息，包括哪个算子产生了反压、反压的时长、反压的等级等信息。