[flink] branch master updated (4a75605 -> 50ff508)

[tw...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

twalthr pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 4a75605  [FLINK-25633] Set locale to en-US to avoid ambiguous decimal formattings
     add 50ff508  [FLINK-25609][table] Anonymous/inline tables don't require ObjectIdentifier anymore

No new revisions were added by this update.

Summary of changes:
 .../delegation/hive/HiveParserDMLHelper.java       |  47 +++---
 .../hive/parse/HiveParserDDLSemanticAnalyzer.java  |  29 ++--
 .../kafka/table/KafkaDynamicTableFactoryTest.java  |   3 +-
 .../table/tests/test_table_environment_api.py      |  11 +-
 .../apache/flink/table/client/cli/CliClient.java   |  10 +-
 .../AbstractStreamTableEnvironmentImpl.java        |  59 ++++---
 .../table/operations/ExternalQueryOperation.java   |  31 ++--
 .../org/apache/flink/table/api/StatementSet.java   |  16 +-
 .../java/org/apache/flink/table/api/Table.java     |  14 +-
 .../apache/flink/table/api/TableEnvironment.java   |  11 +-
 .../flink/table/api/internal/StatementSetImpl.java |  28 ++-
 .../table/api/internal/TableDescriptorUtil.java    |  51 ------
 .../table/api/internal/TableEnvironmentImpl.java   | 139 ++++++++-------
 .../apache/flink/table/api/internal/TableImpl.java |  39 +++--
 .../apache/flink/table/catalog/CatalogManager.java |  73 +++-----
 .../flink/table/catalog/ContextResolvedTable.java  | 188 +++++++++++++++++++++
 .../flink/table/catalog/ExternalCatalogTable.java} |  18 +-
 .../table/operations/CollectModifyOperation.java   |  19 +--
 .../table/operations/ExternalModifyOperation.java  |  33 +---
 .../table/operations/ModifyOperationVisitor.java   |   2 +-
 .../table/operations/QueryOperationVisitor.java    |   2 +-
 ...difyOperation.java => SinkModifyOperation.java} |  32 ++--
 ...eryOperation.java => SourceQueryOperation.java} |  31 ++--
 .../operations/ddl/CreateTableASOperation.java     |  31 +++-
 .../utils/QueryOperationDefaultVisitor.java        |   4 +-
 .../flink/table/api/TableEnvironmentTest.java      |  37 ++--
 .../resolver/ExpressionResolverTest.java           |  28 ++-
 .../flink/table/operations/QueryOperationTest.java |  34 +++-
 .../table/planner/catalog/CatalogSchemaTable.java  |  47 ++----
 .../planner/catalog/DatabaseCalciteSchema.java     |  17 +-
 .../table/planner/connectors/DynamicSinkUtils.java | 137 +++++++--------
 .../planner/connectors/DynamicSourceUtils.java     | 100 +++++------
 .../InternalDataStreamQueryOperation.java          |   1 +
 .../operations/SqlCreateTableConverter.java        |   5 +-
 .../operations/SqlToOperationConverter.java        |  14 +-
 .../planner/plan/FlinkCalciteCatalogReader.java    |  39 ++---
 .../planner/plan/QueryOperationConverter.java      |  35 ++--
 .../nodes/exec/common/CommonExecLookupJoin.java    |   5 +-
 .../nodes/exec/spec/TemporalTableSourceSpec.java   |   8 +-
 .../PushPartitionIntoTableSourceScanRule.java      |  47 ++++--
 .../PushProjectIntoTableSourceScanRule.java        |  14 +-
 .../PushWatermarkIntoTableSourceScanRuleBase.java  |   2 +-
 .../planner/plan/schema/CatalogSourceTable.java    |  80 ++++++---
 .../table/planner/calcite/FlinkRelBuilder.scala    |   2 +-
 .../table/planner/delegation/BatchPlanner.scala    |  34 +---
 .../table/planner/delegation/PlannerBase.scala     |  90 +++++++---
 .../table/planner/delegation/StreamPlanner.scala   |  34 +---
 .../plan/metadata/FlinkRelMdUniqueKeys.scala       |   5 +-
 .../planner/plan/nodes/calcite/LogicalSink.scala   |  16 +-
 .../table/planner/plan/nodes/calcite/Sink.scala    |   9 +-
 .../plan/nodes/logical/FlinkLogicalSink.scala      |  19 +--
 .../nodes/physical/batch/BatchPhysicalSink.scala   |  14 +-
 .../batch/BatchPhysicalTableSourceScan.scala       |   5 +-
 .../physical/common/CommonPhysicalLookupJoin.scala |   2 +-
 .../stream/StreamPhysicalChangelogNormalize.scala  |   9 +-
 .../nodes/physical/stream/StreamPhysicalSink.scala |  17 +-
 .../stream/StreamPhysicalTableSourceScan.scala     |   5 +-
 .../FlinkChangelogModeInferenceProgram.scala       |  27 +--
 .../physical/batch/BatchPhysicalSinkRule.scala     |  18 +-
 .../physical/stream/StreamPhysicalSinkRule.scala   |  18 +-
 .../stream/StreamPhysicalTableSourceScanRule.scala |  11 +-
 .../plan/schema/LegacyCatalogSourceTable.scala     |   9 +-
 .../planner/plan/schema/TableSourceTable.scala     |  26 ++-
 .../table/planner/plan/stats/FlinkStatistic.scala  |   7 +-
 .../flink/table/planner/sinks/TableSinkUtils.scala |   4 +-
 .../operations/SqlToOperationConverterTest.java    |  12 +-
 .../plan/FlinkCalciteCatalogReaderTest.java        |  10 +-
 .../serde/TemporalTableSourceSpecSerdeTest.java    |   9 +-
 .../flink/table/api/TableEnvironmentITCase.scala   |   4 +-
 .../plan/metadata/FlinkRelMdHandlerTestBase.scala  |   3 +-
 .../planner/plan/metadata/MetadataTestUtil.scala   |  47 +++---
 .../planner/plan/stream/sql/TableSinkTest.scala    |   2 +-
 .../validation/LegacyTableSinkValidationTest.scala |   2 +-
 .../flink/table/planner/utils/TableTestBase.scala  |  12 +-
 74 files changed, 1110 insertions(+), 943 deletions(-)
 delete mode 100644 flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/TableDescriptorUtil.java
 create mode 100644 flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/catalog/ContextResolvedTable.java
 rename flink-table/{flink-table-planner/src/main/java/org/apache/flink/table/planner/connectors/InlineCatalogTable.java => flink-table-api-java/src/main/java/org/apache/flink/table/catalog/ExternalCatalogTable.java} (80%)
 rename flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/{CatalogSinkModifyOperation.java => SinkModifyOperation.java} (67%)
 rename flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/operations/{CatalogQueryOperation.java => SourceQueryOperation.java} (61%)