[
https://issues.apache.org/jira/browse/FLINK-13952?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16922341#comment-16922341
]
Jingsong Lee commented on FLINK-13952:
--------------------------------------
Feel free to fix it. I can review your PR.
> 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
> Priority: Major
> 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)
