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 <[email protected]>
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 "