[Flink 日记]Exceeded checkpoint tolerable failure threshold.
org.apache.flink.util.FlinkRuntimeException: Exceeded checkpoint tolerable failure threshold.原因CheckpointTimeout 设置的Checkpoin超时时间内未完成任务 导致的超时异常。解决 1,增加超时时间 2,增加机器性能 。...
·
org.apache.flink.util.FlinkRuntimeException: Exceeded checkpoint tolerable failure threshold.
原因 CheckpointTimeout 设置的Checkpoin超时时间内未完成任务 导致的超时异常。
解决 1,增加超时时间 2,增加机器性能 3,减少数据处理量 :source并行度 和窗口数据量减少,sink 并行度增加
更多推荐
已为社区贡献1条内容
所有评论(0)