[
https://issues.apache.org/jira/browse/FLINK-38022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xuyang Zhong updated FLINK-38022:
---------------------------------
Affects Version/s: 2.1.0
> 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
> Affects Versions: 2.1.0
> Reporter: Sergey Nuyanzin
> Assignee: Xuyang Zhong
> Priority: Critical
> Labels: test-stability
> Fix For: 2.1.0
>
>
> 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([email protected]/Native Method)
> - parking to wait for <0x00000000db074148> (a
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> at
> java.util.concurrent.locks.LockSupport.parkNanos([email protected]/LockSupport.java:252)
> at
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await([email protected]/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)
