You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by "蒋佳成(Jiacheng Jiang)" <92...@qq.com> on 2020/04/30 07:04:20 UTC

execution.checkpointing.tolerable-failed-checkpoints 无效

hi&nbsp;
&nbsp; &nbsp;我在flink-conf.yaml中配置execution.checkpointing.tolerable-failed-checkpoints： 100无效，默认为0，也就是不容忍错误，这样的话一个checkpoint出错，job就要重启，这个值该怎么设置呢？
best
jungglge

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

Posted by Congxian Qiu <qc...@gmail.com>.

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


zhisheng <zh...@gmail.com> 于2020年4月30日周四 下午6:51写道：

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

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

Posted by zhisheng <zh...@gmail.com>.

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

env.getCheckpointConfig().setTolerableCheckpointFailureNumber();

蒋佳成(Jiacheng Jiang) <92...@qq.com> 于2020年4月30日周四 下午3:07写道：

> hi&nbsp;
> &nbsp;
> &nbsp;我在flink-conf.yaml中配置execution.checkpointing.tolerable-failed-checkpoints：
> 100无效，默认为0，也就是不容忍错误，这样的话一个checkpoint出错，job就要重启，这个值该怎么设置呢？
> best
> jungglge