Re: System.exit() vs throwing exception from the pipeline

2018-01-23 Thread Sendoh
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/

System.exit() vs throwing exception from the pipeline

2018-01-22 Thread Gordon Weakliem
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