My source stream means the funciton implement the org.apache.flink.streaming.api.functions.source.SourceFunction. My question is how flink know all working thread is alive? If one working thread that execute the SourceFunction crash, how flink know this happenned?
-- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
