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 <[email protected]>
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(
