Hi team, I'm building a UDF by implementing AbstractRichFunction, where I want to do some resource cleanup per input element when the processing result is committed. I can perform such cleanup in streaming by implementing *CheckpointListener.notifyCheckpointComplete() *but it seems like there is no checkpoint mechanism in batch processing. I'm wondering is* AbstractRichFunction.close() *the good place to do so? How does flink deal with fault tolerance in batch?
Thanks for your help!
