Any exception thrown by your SourceFunction will be caught by Flink and that will mark a task (that was executing this SourceFuntion) as failed.
If you started some custom threads in your SourceFunction, you have to manually propagate their exceptions to the SourceFunction. Piotrek > On Sep 29, 2017, at 2:09 PM, yunfan123 <yunfanfight...@foxmail.com> wrote: > > 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/
