Keyong Zhou created CALCITE-5396:
------------------------------------
Summary: 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
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)
