You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sn...@apache.org on 2026/08/05 12:48:57 UTC
(flink) 04/04: [FLINK-40317][tests] Make DeletesByKeySemanticTests more stable
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 <sn...@gmail.com>
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")