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 于2021年10月18日周一 上午10:27写道：
> Hi!
>
> This is generally "how to capt
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 于2021年10月16日周六 下午10:54写道：
> Can we re
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
