commit 8fa26620f068ba3598c0bc2d92194b703b1de34c
author lincoln lee <lincoln.86xy@gmail.com> Mon Mar 20 17:54:52 2023 +0800
committer Sergey Nuyanzin <snuyanzin@gmail.com> Fri Dec 08 15:59:06 2023 +0100
tree eab563678adbc8d55c34a4328d4ad93cad735667
parent 337e2c7abc80d92fc4d91815fad6c3d59d446bf3

 [FLINK-31487][table-planner] Add targetColumns to DynamicTableSink#Context

This closes #22197

flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParserDMLHelper.java

diff --git a/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParserDMLHelper.java b/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParserDMLHelper.java
index e4cabae..4e016f3 100644
--- a/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParserDMLHelper.java
+++ b/flink-connector-hive/src/main/java/org/apache/flink/table/planner/delegation/hive/HiveParserDMLHelper.java
@@ -340,6 +340,7 @@
                 catalogManager.getTableOrError(insertOperationInfo.f0),
                 insertOperationInfo.f1,
                 insertOperationInfo.f2,
+                null, // targetColumns
                 insertOperationInfo.f3,
                 Collections.emptyMap());
     }
@@ -392,6 +393,7 @@
                         plannerQueryOperation.getResolvedSchema(), props),
                 plannerQueryOperation,
                 Collections.emptyMap(),
+                null, // targetColumns
                 true, // insert into directory is always for overwrite
                 Collections.emptyMap());
     }