Ufuk Celebi created FLINK-5102: ---------------------------------- Summary: Connection establishment does not react to interrupt Key: FLINK-5102 URL: https://issues.apache.org/jira/browse/FLINK-5102 Project: Flink Issue Type: Bug Affects Versions: 1.1.3 Reporter: Ufuk Celebi Assignee: Ufuk Celebi Fix For: 1.2.0, 1.1.4
Interrupting a connection establishment does not to react to interrupts. {code} Task - Task '... (60/120)' did not react to cancelling signal, but is stuck in method: java.lang.Object.$$YJP$$wait(Native Method) java.lang.Object.wait(Object.java) org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory$ConnectingChannel.waitForChannel(PartitionRequestClientFactory.java:191) org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory$ConnectingChannel.access$000(PartitionRequestClientFactory.java:131) org.apache.flink.runtime.io.network.netty.PartitionRequestClientFactory.createPartitionRequestClient(PartitionRequestClientFactory.java:83) org.apache.flink.runtime.io.network.netty.NettyConnectionManager.createPartitionRequestClient(NettyConnectionManager.java:60) org.apache.flink.runtime.io.network.partition.consumer.RemoteInputChannel.requestSubpartition(RemoteInputChannel.java:118) org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.requestPartitions(SingleInputGate.java:395) org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate.getNextBufferOrEvent(SingleInputGate.java:414) org.apache.flink.streaming.runtime.io.BarrierBuffer.getNextNonBlocked(BarrierBuffer.java:152) org.apache.flink.streaming.runtime.io.StreamInputProcessor.processInput(StreamInputProcessor.java:195) org.apache.flink.streaming.runtime.tasks.OneInputStreamTask.run(OneInputStreamTask.java:67) org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:266) org.apache.flink.runtime.taskmanager.Task.run(Task.java:638) java.lang.Thread.run(Thread.java:745) {code} -- This message was sent by Atlassian JIRA (v6.3.4#6332)