[
https://issues.apache.org/jira/browse/FLINK-13952?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Bowen Li closed FLINK-13952.
----------------------------
Resolution: Fixed
master: d32af521cbe83f88cd0b822c4d752a1b5102c47c
> 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
> Assignee: Rui Li
> Priority: Major
> Labels: pull-request-available
> Fix For: 1.10.0
>
> Time Spent: 20m
> Remaining Estimate: 0h
>
> {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)
