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/