Re: Flink Kafka consumer with low latency requirement

Posted by xwang355 on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Flink-Kafka-consumer-with-low-latency-requirement-tp28368p28396.html

Fabian,

Does the above stack trace looks like a deadlock?

        at
org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:539)
        - locked <0x00000007baf84040> (a java.util.ArrayDeque)
        at
org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:508)



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