Kafka source stuck while canceling
Posted by Gyula Fóra on Oct 19, 2015; 10:06am
URL: http://deprecated-apache-flink-mailing-list-archive.368.s1.nabble.com/Kafka-source-stuck-while-canceling-tp8494.html
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.invoke(StreamTask.java:208)
org.apache.flink.runtime.taskmanager.Task.run(Task.java:584)
java.lang.Thread.run(Thread.java:745)
The failure was caused by a different operator in the pipeline, but the job
could never be fully cancelled and restarted due to this error.
Any idea is appreciated :)
Cheers,
Gyula