Flink这个问题怎么处理?我们线上任务里面可能有4-500个sql chain在一起提交,当一个tm failover恢复时,发现jobmanager内存猛增,dump内存发现是akka mailbox中消息过多,还有大量的excution,如果恢复完成能释放,有没有方法能收敛这部分内存,不然可能tm挂的越多,需要的jm内存越大
Flink这个问题怎么处理?[阿里云]
「点点赞赏,手留余香」
还没有人赞赏,快来当第一个赞赏的人吧!
Flink这个问题怎么处理?我们线上任务里面可能有4-500个sql chain在一起提交,当一个tm failover恢复时,发现jobmanager内存猛增,dump内存发现是akka mailbox中消息过多,还有大量的excution,如果恢复完成能释放,有没有方法能收敛这部分内存,不然可能tm挂的越多,需要的jm内存越大