some job is latency critical job which means it can't accept certain threadhold of latency so will flink provide timeout operator in near future which means when one operator timeout, the jobmanager will schedule a new operator which starts from previous state of the OP and keep dealing with new events and discard the events are processing.
-- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
