Hi:
我自定义一个InputFormat,在处理数据的过程中,发生异常,我想要将发生异常的上一个状态保存下来,以便于在问题修复后重启时能接着已经保存的状态点继续处理对应split剩余的数据,但是我又不需要像checkpoint那样,每个隔一段时间保存一下状态。这样的需求该怎么就现有的flink去实现呢?
我用的flink版本:1.12.0




祝好!
automths

回复