[jira] [Closed] (FLINK-5102) Connection establishment does not react to interrupt

["Ufuk Celebi (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-5102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Ufuk Celebi closed FLINK-5102.
------------------------------
    Resolution: Cannot Reproduce

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