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/03 08:08:11 UTC
(flink) branch master updated: [FLINK-40286][table] Adapt keyless upsert sink should fall back to retract to `MiscSemanticTests`
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 0b66c7ee994 [FLINK-40286][table] Adapt keyless upsert sink should fall back to retract to `MiscSemanticTests`
0b66c7ee994 is described below
commit 0b66c7ee9940dc93463b8a146220d92fac1529e6
Author: Sergey Nuyanzin <sn...@gmail.com>
AuthorDate: Mon Aug 3 10:08:03 2026 +0200
[FLINK-40286][table] Adapt keyless upsert sink should fall back to retract to `MiscSemanticTests`
---
.../flink/table/planner/plan/nodes/exec/common/CalcTestPrograms.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/CalcTestPrograms.java b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/CalcTestPrograms.java
index 04c86763757..77a69a6b4e6 100644
--- a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/CalcTestPrograms.java
+++ b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/common/CalcTestPrograms.java
@@ -328,7 +328,7 @@ public class CalcTestPrograms {
.setupTableSink(
SinkTestStep.newBuilder("coalesce_sink")
.addSchema("order_id_str STRING")
- .consumedValues("+I[1]", "+I[2]")
+ .consumedValues("+I[1]", "-D[1]", "+I[1]", "+I[2]")
.build())
.runSql(
"INSERT INTO coalesce_sink "