[jira] [Created] (FLINK-13952) PartitionableTableSink can not work with OverwritableTableSink

[Shang Yuanchun (Jira)]

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)