Hello 大家好 今天遇到个Flink 背压的问题，导致程序完全卡主不在处理数据，从监控页面看是应该是 keyProcess-> sink :alarm state 处理数据有问题，导致上游 ruleProcess 出现背压。 KeyProcess 是中定义了一个MapState，每来一条数据会读取和更新state中的内容。Sink 是写入kafka已排除不是kafka的问题 http://qiniu.lgwen.cn/13F2DE58-98C1-4851-B54A-6BDC3C646169.png， http://qiniu.lgwen.cn/image/jvm.png
Dump了 堆栈日志 http://qiniu.lgwen.cn/docstack.log 没什么排查的思路，如果方便的话，提供一些排查的思路。 Best Aven
