[
https://issues.apache.org/jira/browse/CALCITE-5396?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17637655#comment-17637655
]
Keyong Zhou commented on CALCITE-5396:
--------------------------------------
[~libenchao] Sorry for this, closing the issue.
> Deadlock when kill worker in shuffle read
> -----------------------------------------
>
> Key: CALCITE-5396
> URL: https://issues.apache.org/jira/browse/CALCITE-5396
> Project: Calcite
> Issue Type: Bug
> Reporter: Keyong Zhou
> Priority: Major
>
> sun.misc.Unsafe.park(Native Method)
> java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
> java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467)
> org.apache.celeborn.client.read.WorkerPartitionReader.next(WorkerPartitionReader.java:137)
> org.apache.celeborn.client.read.RssInputStream$RssInputStreamImpl.moveToNextChunk(RssInputStream.java:313)
> org.apache.celeborn.client.read.RssInputStream$RssInputStreamImpl.fillBuffer(RssInputStream.java:334)
> org.apache.celeborn.client.read.RssInputStream$RssInputStreamImpl.read(RssInputStream.java:273)
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
