Flink任务出现延迟排查步奏

桃扇骨 2022-12-30 08:26 143阅读 0赞

1,先查看各个subtask是否有问题,是否出现反压。

2,对存在疑问的operate执行disableChain,强制把链路拆除。观察是否有反压和阻塞情况。

3,增加并行度。

4,如果是计算密集型任务,调到cpu,如果状态或者缓存数据则调到内存。

5, 如果要保存map的数据结构,尽量使用 MapStateDescriptor,不要使用 ValueStateDescriptor

6,查看flink相关计算延迟的代码

发表评论

表情:
评论列表 (有 0 条评论,143人围观)

还没有评论,来说两句吧...

相关阅读