Re: flink不清理state，从checkpoint恢复任务能重置kafka的offset讨论

Wed, 28 Aug 2019 19:26:03 -0700 

可以选择从之前的某个checkpoint恢复吧


在 2019/8/29 上午10:01，“蒋涛涛”<[email protected]> 写入:

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

回复