请问checkpoint失败、超时;task heap慢慢的就满了导致的频繁FullGC,进而导致的一系列问题; 还有managed memory区域也是运行一段时间就满了,目前是hashmap+fs的checkpoint,这个区域也不知道装了什么是什么原因?
请问checkpoint失败、超时是什么原因?[阿里云实时计算 Flink版]
「点点赞赏,手留余香」
还没有人赞赏,快来当第一个赞赏的人吧!
请问checkpoint失败、超时;task heap慢慢的就满了导致的频繁FullGC,进而导致的一系列问题; 还有managed memory区域也是运行一段时间就满了,目前是hashmap+fs的checkpoint,这个区域也不知道装了什么是什么原因?
一是中间数据流动缓慢造成Checkpoint Barrier流动缓慢,二是算子状态过大造成状态数据上传超时。
首先生产上就倾向于用rocksdb状态后端,并开启增量checkpoint此答案出自钉群“【③群】Apache Flink China社区”