[
https://issues.apache.org/jira/browse/FLINK-38022?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=18003472#comment-18003472
]
Xuyang Zhong commented on FLINK-38022:
--------------------------------------
Merged into d4c76dc64b9268aa595218cc58f71a70090103cb.
If the problem occurs again, this PR can be reopened and I'll take a look again.
> 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
> Assignee: Xuyang Zhong
> Priority: Critical
> Labels: test-stability
>
> 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)
