Hi Vino, Regarding this statement "/Checkpoints are taken automatically and are used for automatic restarting job in case of a failure/", I do not quite understand the definition of a failure, and how to simulate that while testing my application. Possible scenarios that I can think of: (1) flink application killed (2) cluster crashed (3) one of the servers in the cluster crashed (4) unhandled exception raised when abnormal data received ...
Could you please help explain? Thanks and regards, Averell -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
