Re: Kafka source stuck while canceling

2015-10-21 Thread Gyula Fóra
I don't think I have the logs for that run anymore, I wasn't smart enough to save it. If I encounter it again I will try to get more info. Thanks, Gyula Stephan Ewen ezt írta (időpont: 2015. okt. 21., Sze, 19:04): > The Kafka consumer API has issue with being interruptible that will > hopefull

Re: Kafka source stuck while canceling

2015-10-21 Thread Stephan Ewen
The Kafka consumer API has issue with being interruptible that will hopefully get better in Kafka 0.8.3. There must be another issue here in addition, though. Does the stacktrace go any deeper than that? I would assume that the main invokable thread is stuck in some blocking method, or in a loop t

Kafka source stuck while canceling

2015-10-19 Thread Gyula Fóra
Hey guys, Has anyone ever got something similar working with the kafka sources? 11:52:48,838 WARN org.apache.flink.runtime.taskmanager.Task - Task 'Source: Kafka[***] (3/4)' did not react to cancelling signal, but is stuck in method: org.apache.flink.streaming.runtime.tasks.StreamTask.inv