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 >
