为什么 flink checkpoint Checkpoint Duration (Async) 阶段耗时很慢

[张立志]

flink 版本1.8
部署集群yarn


配置代码:
StreamExecutionEnvironment.stateBackend(new 
FsStateBackend("hdfs://nsstreaming/streaming/flink_checkpoint/state").checkpointingInterval(1000*60*10).checkpointTimeout(1000*60*10).timeCharacteristic(TimeCharacteristic.IngestionTime).build();
业务代码相对比较简单，内存占用较大
超过10分钟后开始报错，state 大概在1.5G时，开始耗时开始变长