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 12197ea92a5 [FLINK-40285][table] `MLPredictSemanticTests` fails
because of `ON CONFLICT`
12197ea92a5 is described below
commit 12197ea92a5667073bc0c6810e526a39979d835c
Author: Sergey Nuyanzin <[email protected]>
AuthorDate: Mon Aug 3 13:03:12 2026 +0200
[FLINK-40285][table] `MLPredictSemanticTests` fails because of `ON CONFLICT`
---
.../plan/nodes/exec/stream/MLPredictTestPrograms.java | 19 +++++++++++++------
1 file changed, 13 insertions(+), 6 deletions(-)
diff --git
a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/MLPredictTestPrograms.java
b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/MLPredictTestPrograms.java
index 26d4903a3e4..205aa672e25 100644
---
a/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/MLPredictTestPrograms.java
+++
b/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/nodes/exec/stream/MLPredictTestPrograms.java
@@ -20,6 +20,7 @@ package org.apache.flink.table.planner.plan.nodes.exec.stream;
import org.apache.flink.table.api.DataTypes;
import org.apache.flink.table.api.Expressions;
+import org.apache.flink.table.api.InsertConflictStrategy;
import org.apache.flink.table.api.ModelDescriptor;
import org.apache.flink.table.api.Schema;
import org.apache.flink.table.api.config.ExecutionConfigOptions;
@@ -182,7 +183,8 @@ public class MLPredictTestPrograms {
env.from("features").asArgument("INPUT"),
env.fromModel("chatgpt").asArgument("MODEL"),
descriptor("feature").asArgument("ARGS")),
- "sink")
+ "sink",
+ InsertConflictStrategy.deduplicate())
.build();
public static final TableTestProgram ASYNC_ML_PREDICT_TABLE_API =
@@ -209,7 +211,8 @@ public class MLPredictTestPrograms {
DataTypes.STRING())
.notNull())
.asArgument("CONFIG")),
- "sink")
+ "sink",
+ InsertConflictStrategy.deduplicate())
.build();
public static final TableTestProgram
ASYNC_ML_PREDICT_TABLE_API_MAP_EXPRESSION_CONFIG =
@@ -235,7 +238,8 @@ public class MLPredictTestPrograms {
"max-concurrent-operations",
"10")
.asArgument("CONFIG")),
- "sink")
+ "sink",
+ InsertConflictStrategy.deduplicate())
.build();
public static final TableTestProgram ML_PREDICT_MODEL_API =
@@ -248,7 +252,8 @@ public class MLPredictTestPrograms {
env.fromModel("chatgpt")
.predict(
env.from("features"),
ColumnList.of("feature")),
- "sink")
+ "sink",
+ InsertConflictStrategy.deduplicate())
.build();
public static final TableTestProgram ASYNC_ML_PREDICT_MODEL_API =
@@ -270,7 +275,8 @@ public class MLPredictTestPrograms {
"true",
"max-concurrent-operations",
"10")),
- "sink")
+ "sink",
+ InsertConflictStrategy.deduplicate())
.build();
public static final TableTestProgram ML_PREDICT_ANON_MODEL_API =
@@ -304,6 +310,7 @@ public class MLPredictTestPrograms {
.build())
.predict(
env.from("features"),
ColumnList.of("feature")),
- "sink")
+ "sink",
+ InsertConflictStrategy.deduplicate())
.build();
}
