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
commit e76147fe65ce59820be5dd7cee9c4b9ce901b680 Author: Sergey Nuyanzin <[email protected]> AuthorDate: Mon Aug 3 20:13:56 2026 +0200 [FLINK-40317][tests] Make DeletesByKeySemanticTests more stable --- .../plan/nodes/exec/stream/DeletesByKeyPrograms.java | 18 ++++-------------- 1 file changed, 4 insertions(+), 14 deletions(-) diff --git a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/DeletesByKeyPrograms.java b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/DeletesByKeyPrograms.java index 6599f649950..a66837d1c45 100644 --- a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/DeletesByKeyPrograms.java +++ b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/DeletesByKeyPrograms.java @@ -237,13 +237,8 @@ public final class DeletesByKeyPrograms { "`value` INT") .addOption("changelog-mode", "I,UA,D") .addOption("sink.supports-delete-by-key", "false") - .consumedValues( - "+I[1, Alice, 10]", - "+I[2, Bob, 20]", - "+I[3, Emily, 30]", - "-D[1, Alice, 10]", - "+U[3, Emily, 40]", - "+U[2, BOB, 20]") + .testMaterializedData() + .consumedValues("+I[3, Emily, 40]", "+I[2, BOB, 20]") .build()) .runSql( "INSERT INTO sink_t SELECT l.id, r.name, l.`value` FROM left_t l JOIN right_t r ON l.id = r.id") @@ -291,13 +286,8 @@ public final class DeletesByKeyPrograms { "`value` INT") .addOption("changelog-mode", "I,UA,D") .addOption("sink.supports-delete-by-key", "true") - .consumedValues( - "+I[1, Alice, 10]", - "+I[2, Bob, 20]", - "+I[3, Emily, 30]", - "-D[1, Alice, null]", - "+U[3, Emily, 40]", - "+U[2, BOB, 20]") + .testMaterializedData() + .consumedValues("+I[2, BOB, 20]", "+I[3, Emily, 40]") .build()) .runSql( "INSERT INTO sink_t SELECT l.id, r.name, l.`value` FROM left_t l JOIN right_t r ON l.id = r.id")
