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