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

snuyanzin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 9501264941a [FLINK-40363][table] Make 
`MiscSemanticTests#COALESCE_NESTED_ROW_LEFT_JOIN` more stable
9501264941a is described below

commit 9501264941a447db239142c084e7f4f866f1b3e6
Author: Sergey Nuyanzin <[email protected]>
AuthorDate: Mon Aug 10 22:11:17 2026 +0200

    [FLINK-40363][table] Make `MiscSemanticTests#COALESCE_NESTED_ROW_LEFT_JOIN` 
more stable
---
 .../flink/table/planner/plan/nodes/exec/common/CalcTestPrograms.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/CalcTestPrograms.java
 
b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/CalcTestPrograms.java
index 77a69a6b4e6..e7abd8de940 100644
--- 
a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/CalcTestPrograms.java
+++ 
b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/CalcTestPrograms.java
@@ -328,7 +328,8 @@ public class CalcTestPrograms {
                     .setupTableSink(
                             SinkTestStep.newBuilder("coalesce_sink")
                                     .addSchema("order_id_str STRING")
-                                    .consumedValues("+I[1]", "-D[1]", "+I[1]", 
"+I[2]")
+                                    .testMaterializedData()
+                                    .consumedValues("+I[1]", "+I[2]")
                                     .build())
                     .runSql(
                             "INSERT INTO coalesce_sink "

Reply via email to