Hi, currently, messaged in flight will be dropped if a streaming job gets canceled.
There is already WIP to add a STOP signal which allows for a clean shutdown of a streaming job. This should get merged soon and will be available in Flink 1.0. You can follow the JIRA an PR here: https://issues.apache.org/jira/browse/FLINK-2111 https://github.com/apache/flink/pull/750 -Matthias On 01/18/2016 08:26 PM, Don Frascuchon wrote: > Hi, > > When some streaming job is manually canceled, what's about the messages > in process ? Flink's engine wait to task finish process messages inside > (some like apache-storm) ? If not, there is a safe way for stop > streaming jobs ? > > Thanks in advance! > Best regards
signature.asc
Description: OpenPGP digital signature
