Hi Yi and all I was wondering if there is a “clean” way of shutting down a samza task.
I’m intersted in doing some cleanup and state handling for a graceful shutdown. I am aware of the closable task implementation, but, that is not called using a yarn application -kill If there is a better way, please let me know. If not, is there a JIRA assigned? Thanks Maor