flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zhisheng <zhisheng2...@gmail.com>
Subject Re: execution.checkpointing.tolerable-failed-checkpoints 无效
Date Thu, 30 Apr 2020 10:50:46 GMT
这个参数好像可以作业里面单独设置,可以试试看

env.getCheckpointConfig().setTolerableCheckpointFailureNumber();

蒋佳成(Jiacheng Jiang) <920334586@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
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message