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
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
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