flink checkpoinnt失败
flink checkpoinnt 失败的原因见 https://blog.****.net/yunqiinsight/article/details/100918041
总结下就是: 作业出现了反压
解决方法:
- 增加并行度, 解决反压
- 增加checkpoint 超时时间 env.getCheckpointConfig().setCheckpointTimeout(TimeUnit.MINUTES.toMillis(30));
- 增加可以容忍checkpoinnt 失败的个数 env.getCheckpointConfig().setTolerableCheckpointFailureNumber(50);