这个参数好像可以作业里面单独设置,可以试试看
env.getCheckpointConfig().setTolerableCheckpointFailureNumber();
蒋佳成(Jiacheng Jiang) <
[hidden email]> 于2020年4月30日周四 下午3:07写道:
> hi
>
> 我在flink-conf.yaml中配置execution.checkpointing.tolerable-failed-checkpoints:
> 100无效,默认为0,也就是不容忍错误,这样的话一个checkpoint出错,job就要重启,这个值该怎么设置呢?
> best
> jungglge