[
https://issues.apache.org/jira/browse/FLINK-40568?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Martijn Visser reopened FLINK-40568:
------------------------------------
Reopening for the release branches, the same failure on release-2.2 and
release-2.3, where the fix is not in:
release-2.2, nightly 2026-09-20:
https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=79268&view=logs&j=a9db68b9-a7e0-54b6-0f98-010e0aff39e2
release-2.2, nightly 2026-09-21:
https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=79301&view=logs&j=a9db68b9-a7e0-54b6-0f98-010e0aff39e2
release-2.2, nightly 2026-09-24:
https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=79373&view=logs&j=a9db68b9-a7e0-54b6-0f98-010e0aff39e2
release-2.3, nightly 2026-09-18:
https://dev.azure.com/apache-flink/98463496-1af2-4620-8eab-a2ecc1a2e6fe/_build/results?buildId=79225&view=logs&j=0c940707-2659-5648-cbe6-a1ad63045f0a
{code}
[ERROR]
org.apache.flink.table.planner.plan.nodes.exec.stream.ProcessTableFunctionSemanticTests.runSteps(TableTestProgram)[57]
-- Time elapsed: 0.735 s <<< FAILURE!
java.lang.AssertionError:
[process-updating-multi-input]
Expecting actual:
["+I[Bob, score 2 in city London]",
"+I[Alice, score 2 in city Zurich]",
"-D[Alice, null]",
"+U[Bob, score 2 in city Berlin]"]
to contain exactly in any order:
["+I[Bob, score 5 in city London]",
"+I[Alice, score 2 in city Zurich]",
"+U[Bob, score 3 in city London]",
"+U[Bob, score 3 in city Berlin]",
"-D[Bob, null]",
"+I[Bob, score 2 in city Berlin]",
"-D[Alice, null]"]
{code}
> ProcessTableFunctionSemanticTests[process-updating-multi-input] is flaky on
> master
> ----------------------------------------------------------------------------------
>
> Key: FLINK-40568
> URL: https://issues.apache.org/jira/browse/FLINK-40568
> Project: Flink
> Issue Type: Bug
> Components: Table SQL / Planner
> Affects Versions: 2.4.0
> Reporter: Purushottam Sinha
> Assignee: Purushottam Sinha
> Priority: Major
> Labels: pull-request-available, test-stability
> Fix For: 2.4.0
>
>
> h3. Problem
> {{ProcessTableFunctionSemanticTests}} is flaky on master for the
> {{process-updating-multi-input}} program. It runs the two-input updating PTF
> join {{UpdatingJoinFunction}} and asserts the sink's raw changelog with
> {{{}containsExactlyInAnyOrder{}}}, but a two-input operator has no
> deterministic cross-input arrival order, so the emitted changelog varies. The
> test pins one interleaving, so an alternate order fails the assertion.
> h3. Evidence
> * master run
> [https://github.com/apache/flink/actions/runs/33989974423/job/101371696744] —
> {{runSteps(TableTestProgram)[64]}} {{{}[process-updating-multi-input]{}}},
> {{{}Tests run: 11458, Failures: 1{}}}.
> * Failing assertion (job is awaited, so this is the complete output, not a
> truncation):
> {noformat}
> Expecting actual:
> ["+I[Bob, score 2 in city London]", "+U[Bob, score 2 in city Berlin]"]
> to contain exactly in any order:
> ["+I[Bob, score 5 in city London]", "+I[Alice, score 2 in city Zurich]",
> "+U[Bob, score 3 in city London]", "+U[Bob, score 3 in city Berlin]",
> "-D[Bob, null]", "+I[Bob, score 2 in city Berlin]", "-D[Alice, null]"]
> {noformat}
> * The failing run's head SHA is current master ({{{}c51e71536ed{}}}); the
> same commit passed 51/51 local runs (JDK 17), so this is a flake, not a
> regression at this commit.
> h3. Notes
> * The final upsert-materialized result converges across interleavings; only
> the raw changelog differs. A fix could assert the materialized result instead
> of the raw changelog for this program, or otherwise make the expectation
> interleave-independent.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
