You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by automths <au...@163.com> on 2021/01/06 05:44:01 UTC

自定义InputFormat在发生异常时状态如何保存

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




祝好！
automths