Hi, Would you please describe your demand in more detail? Do you want to release resource when the job is closing? If yes, you could overwrite the close() method of the custom source and custom sink.
Best, JING ZHANG Caizhi Weng <tsreape...@gmail.com> 于2021年10月18日周一 上午10:27写道： > Hi! > > This is generally "how to capture SIGINT in Java". See [1] for the answer. > > By the way, can you briefly explain why you want to do this in your custom > source and sink? > > [1] https://stackoverflow.com/questions/2541475/capture-sigint-in-java > > Vijay Bhaskar <bhaskar.eba...@gmail.com> 于2021年10月16日周六 下午10:54写道： > >> Can we register any method in Custom Source and Custom Sink to catch >> SIGINIT? (I know that we need to follow procedure to stop a flink job by >> saving the state.) >> >> Regards >> Bhaskar >> >
