Sergey Nuyanzin created FLINK-38022:
---------------------------------------
Summary: StreamingDeltaJoinOperator hangs with timeout
Key: FLINK-38022
URL: https://issues.apache.org/jira/browse/FLINK-38022
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Reporter: Sergey Nuyanzin
It is flaky, for some reason it is not reproduced in AZP
however it is often reproduced in GH actions like
{noformat}
java.lang.Thread.State: TIMED_WAITING (parking)
at jdk.internal.misc.Unsafe.park(java.base@17.0.7/Native Method)
- parking to wait for <0x00000000db074148> (a
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
at
java.util.concurrent.locks.LockSupport.parkNanos(java.base@17.0.7/LockSupport.java:252)
at
java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(java.base@17.0.7/AbstractQueuedSynchronizer.java:1757)
at
org.apache.flink.streaming.runtime.tasks.mailbox.TaskMailboxImpl.take(TaskMailboxImpl.java:161)
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxExecutorImpl.yield(MailboxExecutorImpl.java:91)
at
org.apache.flink.table.runtime.operators.join.deltajoin.StreamingDeltaJoinOperator.waitInFlightInputsFinished(StreamingDeltaJoinOperator.java:472)
at
org.apache.flink.table.runtime.operators.join.deltajoin.StreamingDeltaJoinOperator.endInput(StreamingDeltaJoinOperator.java:457)
at
org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.endOperatorInput(StreamOperatorWrapper.java:98)
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.endInput(RegularOperatorChain.java:97)
at
org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:68)
at
org.apache.flink.streaming.runtime.io.StreamMultipleInputProcessor.processInput(StreamMultipleInputProcessor.java:86)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:638)
{noformat}
https://github.com/apache/flink/actions/runs/15813737836/job/44569078501#step:12:14872
or
https://github.com/apache/flink/actions/runs/15813737836/job/44569078501#step:12:14881
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
