[flink] branch master updated (bde1251 -> 335c4f7)

[ku...@apache.org]

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(-)