flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From 蒋涛涛 <jttsai1...@gmail.com>
Subject flink不清理state,从checkpoint恢复任务能重置kafka的offset讨论
Date Thu, 29 Aug 2019 02:00:54 GMT
Hi everyone:

如题,我遇到有些数据我不应该漏了想回溯部分数据,这个时候我就需要清理state,来重置kafka的offset重新跑,可不可以保留flink任务state,从checkpoint恢复任务的时候重置kafka的offset,并从kafka那个时间段开始消费,而不需要清掉state重新跑数据。

Regards,
JackJiang
Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message