(flink) branch release-2.2 updated: [FLINK-40683][table] Assert materialized data in the anti-join-on-nested semantic test

[ma...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

MartijnVisser pushed a commit to branch release-2.2
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-2.2 by this push:
     new 32d39f631f0 [FLINK-40683][table] Assert materialized data in the anti-join-on-nested semantic test
32d39f631f0 is described below

commit 32d39f631f0dd18e82a211979b367814cabff623
Author: Martijn Visser <29...@users.noreply.github.com>
AuthorDate: Wed Sep 16 16:18:21 2026 +0200

    [FLINK-40683][table] Assert materialized data in the anti-join-on-nested semantic test
    
    The sink asserted the raw changelog, so the test failed on the transient
    +I[test_same] and -D[test_same] that the anti join emits when the probe row
    arrives before the build row. Master has asserted the materialized result for
    this program since FLINK-39695, which is master-only.
    
    Generated-by: Claude Code (Claude Opus 5)
---
 .../table/planner/plan/nodes/exec/common/JoinSemanticTestPrograms.java   | 1 +
 1 file changed, 1 insertion(+)

diff --git a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/JoinSemanticTestPrograms.java b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/JoinSemanticTestPrograms.java
index b687f5d4a18..72ce8361254 100644
--- a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/JoinSemanticTestPrograms.java
+++ b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/JoinSemanticTestPrograms.java
@@ -104,6 +104,7 @@ public class JoinSemanticTestPrograms {
                     .setupTableSink(
                             SinkTestStep.newBuilder("sink_t")
                                     .addSchema("output STRING")
+                                    .testMaterializedData()
                                     .consumedValues("+I[test_diff]")
                                     .build())
                     .runSql(