As I understood if wanted a smooth shutdown, it's recommend to throw
exception, and then cancel() is called, where you can even write your own.
Don't think it's the same as System.exit()
Cheers,
Sendoh
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
What's the general advice on calling System.exit() inside an operator, vs
throwing an exception and having the execution environment tear down the
pipeline. Throwing the exception seems cleaner but it does appear that
Flink might do an orderly shutdown with System.exit(). Will the close()
methods b