flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Piotr Nowojski <pi...@data-artisans.com>
Subject Re: How flink monitor source stream task(Time Trigger) is running?
Date Fri, 29 Sep 2017 13:01:48 GMT
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.


> On Sep 29, 2017, at 2:09 PM, yunfan123 <yunfanfighting@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/

View raw message