Jingsong Lee created FLINK-13952:
------------------------------------
Summary: PartitionableTableSink can not work with
OverwritableTableSink
Key: FLINK-13952
URL: https://issues.apache.org/jira/browse/FLINK-13952
Project: Flink
Issue Type: Bug
Components: Table SQL / Planner
Reporter: Jingsong Lee
Fix For: 1.10.0
{code:java}
tableSink match {
case partitionableSink: PartitionableTableSink
if partitionableSink.getPartitionFieldNames != null
&& partitionableSink.getPartitionFieldNames.nonEmpty =>
partitionableSink.setStaticPartition(insertOptions.staticPartitions)
case overwritableTableSink: OverwritableTableSink =>
overwritableTableSink.setOverwrite(insertOptions.overwrite)
{code}
Code in TableEnvImpl and PlannerBase
overwrite will not be invoked when there are static partition columns.
--
This message was sent by Atlassian Jira
(v8.3.2#803003)
