[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

latency critical job

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/