Re: How graceful shutdown or resource clean up happens in Flink at task level ?

Thanks Stefan . -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Re: How graceful shutdown or resource clean up happens in Flink at task level ?

Hi, the user function’s close() method is called in AbstractStreamOperator::close() and ::dispose(). The invocation of the user function’s close() in AbstractStreamOperator::dispose() only has an effect if there was no previous invocation of the method through AbstractStreamOperator::close().

How graceful shutdown or resource clean up happens in Flink at task level ?

Let's assume I have following class : public class TestFlatMap extends RichFlatMapFunction { private Connection connection ; @Override public void open(Configuration parameters) throws Exception { super.open(parameters); //