Re: flink任务失败重启时, flink last checkpoint 失败但任务仍然正常重启,导致 state 重启前后不一致
Hi , 正如 Congxian 所说,当 Flink 任务容错恢复重启时,会从上一次成功的 Checkpoint 进行恢复。 所以你所说的 last checkpoint 失败,具体是什么含义呢? Best, LakeShen Congxian Qiu 于2020年6月22日周一 下午8:23写道: > hi > > 这里说的 state 不一致是什么意思呢?checkpoint 恢复保证全局的 state 被重置到之前某个成功的 checkpoint。 > > Best, > Congxian > > > 莫失莫忘 于2020年6月22日周一 下午8:09写道: > > > 如题,可以要求flink失败重启时 必须正常从checkpoint恢复,否则就重启失败吗? >
Re: flink任务失败重启时, flink last checkpoint 失败但任务仍然正常重启,导致 state 重启前后不一致
hi 这里说的 state 不一致是什么意思呢?checkpoint 恢复保证全局的 state 被重置到之前某个成功的 checkpoint。 Best, Congxian 莫失莫忘 于2020年6月22日周一 下午8:09写道: > 如题,可以要求flink失败重启时 必须正常从checkpoint恢复,否则就重启失败吗?