This is an automated email from the ASF dual-hosted git repository. kurt pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/flink.git.
from bde1251 [hotfix][table-planner] Remove unused import in CalcITCase add 7c11822 [FLINK-14381][table-planner] Remove dynamic partition shuffle support in legacy planner add fcc4b7f [FLINK-14381][table-planner-blink] User table factory and catalog table to test partition source and sink add ad4fd63 [FLINK-14381][table-planner-blink] Get partition keys from catalog table for PartitionableTableSink add 8e0d8ac [FLINK-14381][table-planner-blink] Get partition keys from catalog table for PartitionableTableSource add 335c4f7 [FLINK-14381][table-planner-blink] Remove getPartitionFieldNames in PartitionableTableSource and PartitionableTableSink No new revisions were added by this update. Summary of changes: .../flink/connectors/hive/HiveTableSink.java | 3 +- .../flink/connectors/hive/HiveTableSource.java | 5 - .../flink/table/sinks/PartitionableTableSink.java | 16 +- .../table/sources/PartitionableTableSource.java | 14 +- .../planner/catalog/DatabaseCalciteSchema.java | 6 +- .../planner/plan/QueryOperationConverter.java | 3 +- .../calcite/RelTimeIndicatorConverter.scala | 3 +- .../table/planner/delegation/PlannerBase.scala | 39 ++--- .../planner/plan/nodes/calcite/LogicalSink.scala | 13 +- .../plan/nodes/logical/FlinkLogicalSink.scala | 16 +- .../PushFilterIntoTableSourceScanRule.scala | 5 +- .../PushPartitionIntoTableSourceScanRule.scala | 30 ++-- .../PushProjectIntoTableSourceScanRule.scala | 3 +- .../rules/physical/batch/BatchExecSinkRule.scala | 43 ++--- .../rules/physical/stream/StreamExecSinkRule.scala | 41 ++--- .../planner/plan/schema/TableSourceTable.scala | 17 +- .../flink/table/planner/sinks/TableSinkUtils.scala | 42 ++--- .../org.apache.flink.table.factories.TableFactory | 2 + .../planner/plan/batch/sql/TableSourceTest.scala | 4 +- .../PushPartitionIntoTableSourceScanRuleTest.scala | 4 +- .../planner/plan/stream/sql/TableSourceTest.scala | 4 +- .../batch/sql/PartitionableSinkITCase.scala | 182 +++++++++++++-------- .../runtime/batch/sql/TableSourceITCase.scala | 6 +- .../runtime/stream/sql/TableSourceITCase.scala | 4 +- .../table/planner/utils/testTableSources.scala | 83 +++++++++- .../table/api/internal/BatchTableEnvImpl.scala | 26 +-- .../flink/table/api/internal/TableEnvImpl.scala | 4 +- .../apache/flink/table/planner/StreamPlanner.scala | 32 +--- .../apache/flink/table/sinks/TableSinkUtils.scala | 28 +--- .../batch/sql/PartitionableSinkITCase.scala | 139 +++------------- 30 files changed, 373 insertions(+), 444 deletions(-)