(flink) branch release-2.2 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.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 8e5821dad58 [FLINK-39729][table] Fix flaky CorrelateRestoreTest by 
using materialized data assertion
8e5821dad58 is described below

commit 8e5821dad5850f4ab9acf58b1bf04cd85b3afe3f
Author: Jim Hughes <jhug...@confluent.io>
AuthorDate: Fri May 22 16:52:51 2026 -0400

    [FLINK-39729][table] Fix flaky CorrelateRestoreTest by using materialized 
data assertion
---
 .../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 "