flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aven.wu <danxieai...@163.com>
Subject Flink 严重背压问题排查
Date Mon, 11 May 2020 13:43:21 GMT
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

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message