(flink) branch release-2.1 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 release-2.1
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-2.1 by this push:
     new bc47ca1ced9 [FLINK-39729][table] Fix flaky CorrelateRestoreTest by 
using materialized data assertion
bc47ca1ced9 is described below

commit bc47ca1ced9bf6e684410430ffa78f55701d2cde
Author: Jim Hughes <jhug...@confluent.io>
AuthorDate: Fri May 22 12:33:08 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 cb1127fa457..5da168f3b65 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
@@ -225,8 +225,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 "