Flink异常指南

一、Checkpoint失败:Checkpoint expired before completing env.enableCheckpointing(1000L) val checkpointConf = env.getCheckpointConfig checkpointConf.setMinPauseBetweenCheckpoints(30000L)
相关文章
相关标签/搜索