execution.checkpointing.tolerable-failed-checkpoints 无效

classic Classic list List threaded Threaded
3 messages Options
Reply | Threaded
Open this post in threaded view
|

execution.checkpointing.tolerable-failed-checkpoints 无效

蒋佳成(Jiacheng Jiang)
hi 
   我在flink-conf.yaml中配置execution.checkpointing.tolerable-failed-checkpoints: 100无效,默认为0,也就是不容忍错误,这样的话一个checkpoint出错,job就要重启,这个值该怎么设置呢?
best
jungglge
Reply | Threaded
Open this post in threaded view
|

Re: execution.checkpointing.tolerable-failed-checkpoints 无效

zhisheng
这个参数好像可以作业里面单独设置,可以试试看

env.getCheckpointConfig().setTolerableCheckpointFailureNumber();

蒋佳成(Jiacheng Jiang) <[hidden email]> 于2020年4月30日周四 下午3:07写道:

> hi&nbsp;
> &nbsp;
> &nbsp;我在flink-conf.yaml中配置execution.checkpointing.tolerable-failed-checkpoints:
> 100无效,默认为0,也就是不容忍错误,这样的话一个checkpoint出错,job就要重启,这个值该怎么设置呢?
> best
> jungglge
Reply | Threaded
Open this post in threaded view
|

Re: execution.checkpointing.tolerable-failed-checkpoints 无效

Congxian Qiu
Hi
按理说 1.10 中在 flink-conf 中配置的应该是可以的,具体的 issue 可以参考[1] 请问你用的是啥版本呢?
[1] https://issues.apache.org/jira/browse/FLINK-14788
Best,
Congxian


zhisheng <[hidden email]> 于2020年4月30日周四 下午6:51写道:

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