(flink) branch master updated: [FLINK-39729][table] Fix flaky CorrelateRestoreTest by using materialized data assertion

[snuyanzin]

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 2741d9659d5 [FLINK-39729][table] Fix flaky CorrelateRestoreTest by 
using materialized data assertion
2741d9659d5 is described below

commit 2741d9659d5c9ac21a7bb52c613baa522f6967cc
Author: Jim Hughes <jhug...@confluent.io>
AuthorDate: Fri May 22 09:33:36 2026 -0400

    [FLINK-39729][table] Fix flaky CorrelateRestoreTest by using materialized 
data assertion
    
    Generated-by: Claude Code (claude-opus-4-6)
---
 .../table/planner/plan/nodes/exec/common/CorrelateTestPrograms.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/CorrelateTestPrograms.java
 
b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/CorrelateTestPrograms.java
index 44bf5b351b1..5edce14b726 100644
--- 
a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/CorrelateTestPrograms.java
+++ 
b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/CorrelateTestPrograms.java
@@ -272,8 +272,8 @@ public class CorrelateTestPrograms {
                     .setupTableSink(
                             SinkTestStep.newBuilder("sink_t")
                                     .addSchema("b BIGINT")
-                                    .consumedBeforeRestore(
-                                            "+I[2]", "+I[3]", "-D[2]", 
"-D[3]", "+I[2]", "+I[3]")
+                                    .consumedValues("+I[2]", "+I[3]")
+                                    .testMaterializedData()
                                     .build())
                     .runSql(
                             "INSERT INTO sink_t SELECT b FROM source_t1 "