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 "

Reply via email to