Re: How flink monitor source stream task(Time Trigger) is running?

Posted by Aljoscha Krettek on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/How-flink-monitor-source-stream-task-Time-Trigger-is-running-tp15937p16141.html

I think this might not actually be resolved. What YunFan was referring to in the initial mail is the Thread factory that is used for the processing-time service: https://github.com/apache/flink/blob/5af463a9c0ff62603bc342a78dfd5483d834e8a7/flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/StreamTask.java#L223

How likely is it that a ScheduledThreadPoolExecutor simply fails? I don't think we currently have a mechanism that checks whether this service is still alive and would actually start scheduled tasks.

Best,

Aljoscha

On 4. Oct 2017, at 09:27, Piotr Nowojski <[hidden email]> wrote:

You are welcome :)

Piotrek

On Oct 2, 2017, at 1:19 PM, yunfan123 <[hidden email]> wrote:

Thank you. 
"If SourceFunction.run methods returns without an exception Flink assumes
that it has cleanly shutdown and that there were simply no more elements to
collect/create by this task. "
This sentence solve my confusion.




--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/