[flink] branch master updated (6f05e6f -> a09cc47)

[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 6f05e6f  [FLINK-25080][tests] Move tests to flink-core
     add a09cc47  [FLINK-25047][table] Resolve architectural violations

No new revisions were added by this update.

Summary of changes:
 .../5b9eed8a-5fb6-4373-98ac-3be2a71941b8           | 275 +--------------------
 .../7602816f-5c01-4b7a-9e3e-235dfedec245           |  29 +--
 .../e5126cae-f3fe-48aa-b6fb-60ae6cc3fcd5           |  12 +-
 .../flink/table/catalog/hive/HiveCatalog.java      |   7 +-
 .../org/apache/flink/util/CloseableIterator.java   |   3 +
 .../org/apache/flink/table/api/ApiExpression.java  |   2 +
 .../flink/table/api/EnvironmentSettings.java       |   1 +
 .../apache/flink/table/api/FormatDescriptor.java   |   1 +
 .../apache/flink/table/api/TableDescriptor.java    |   1 +
 .../table/api/config/ExecutionConfigOptions.java   |   2 +
 .../apache/flink/table/catalog/CatalogManager.java |   4 +-
 .../flink/table/operations/QueryOperation.java     |   4 +-
 .../table/api/AmbiguousTableFactoryException.java  |  12 +-
 .../java/org/apache/flink/table/api/DataTypes.java |   4 +
 .../flink/table/api/ExpressionParserException.java |  13 +-
 .../table/api/NoMatchingTableFactoryException.java |  12 +-
 .../java/org/apache/flink/table/api/Schema.java    |   8 +
 .../org/apache/flink/table/api/TableColumn.java    |   3 +
 .../org/apache/flink/table/api/TableSchema.java    |   1 +
 .../flink/table/api/constraints/Constraint.java    |   1 +
 .../flink/table/catalog/CatalogBaseTable.java      |   1 +
 .../flink/table/catalog/CatalogDatabase.java       |   3 +
 .../flink/table/catalog/CatalogFunction.java       |   3 +
 .../flink/table/catalog/CatalogPartition.java      |   3 +
 .../flink/table/catalog/CatalogPartitionSpec.java  |   3 +
 .../org/apache/flink/table/catalog/Column.java     |   3 +
 .../org/apache/flink/table/catalog/Constraint.java |   1 +
 .../flink/table/catalog/ObjectIdentifier.java      |   2 +
 .../org/apache/flink/table/catalog/ObjectPath.java |   2 +
 .../flink/table/catalog/UnresolvedIdentifier.java  |   4 +-
 .../exceptions/DatabaseAlreadyExistException.java  |   3 +
 .../exceptions/DatabaseNotEmptyException.java      |   3 +
 .../exceptions/DatabaseNotExistException.java      |   3 +
 .../exceptions/FunctionAlreadyExistException.java  |   2 +
 .../exceptions/FunctionNotExistException.java      |   2 +
 .../PartitionAlreadyExistsException.java           |   2 +
 .../exceptions/PartitionNotExistException.java     |   2 +
 .../exceptions/PartitionSpecInvalidException.java  |   2 +
 .../exceptions/TableAlreadyExistException.java     |   2 +
 .../catalog/exceptions/TableNotExistException.java |   2 +
 .../exceptions/TableNotPartitionedException.java   |   2 +
 .../exceptions/TablePartitionedException.java      |   2 +
 .../catalog/stats/CatalogColumnStatistics.java     |   3 +
 .../stats/CatalogColumnStatisticsDataBase.java     |   3 +
 .../catalog/stats/CatalogTableStatistics.java      |   3 +
 .../flink/table/connector/ChangelogMode.java       |   1 +
 .../flink/table/connector/RuntimeConverter.java    |   1 +
 .../table/connector/sink/DynamicTableSink.java     |   3 +
 .../table/connector/source/DynamicTableSource.java |   2 +
 .../table/connector/source/LookupTableSource.java  |   2 +
 .../table/connector/source/ScanTableSource.java    |   2 +
 .../source/abilities/SupportsFilterPushDown.java   |   1 +
 .../org/apache/flink/table/data/ArrayData.java     |   1 +
 .../java/org/apache/flink/table/data/RowData.java  |   1 +
 .../ExpressionParserException.java                 |  14 +-
 .../factories/AmbiguousTableFactoryException.java  |  52 ++++
 .../flink/table/factories/CatalogFactory.java      |   1 +
 .../flink/table/factories/DynamicTableFactory.java |   1 +
 .../apache/flink/table/factories/FactoryUtil.java  |   4 +-
 .../table/factories/FunctionDefinitionFactory.java |   2 +
 .../flink/table/factories/ModuleFactory.java       |   1 +
 .../factories/NoMatchingTableFactoryException.java |  64 +++++
 .../flink/table/factories/TableFactoryService.java |   2 -
 .../flink/table/factories/TableSinkFactory.java    |   1 +
 .../flink/table/factories/TableSourceFactory.java  |   1 +
 .../functions/BuiltInFunctionDefinitions.java      |   2 +
 .../flink/table/functions/SpecializedFunction.java |   1 +
 .../flink/table/types/inference/Signature.java     |   1 +
 .../flink/table/types/inference/TypeInference.java |   1 +
 .../table/types/logical/DayTimeIntervalType.java   |   1 +
 .../flink/table/types/logical/DistinctType.java    |   1 +
 .../apache/flink/table/types/logical/RowType.java  |   1 +
 .../flink/table/types/logical/StructuredType.java  |   3 +
 .../table/types/logical/YearMonthIntervalType.java |   1 +
 .../factories/TableSinkFactoryServiceTest.java     |   2 -
 .../planner/expressions}/UnresolvedException.java  |   5 +-
 .../nodes/exec/processor/utils/TopologyGraph.java  |   2 -
 .../table/data/writer/AbstractBinaryWriter.java    |   3 +-
 78 files changed, 298 insertions(+), 339 deletions(-)
 copy flink-table/flink-table-common/src/main/java/org/apache/flink/table/{api => expressions}/ExpressionParserException.java (69%)
 create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/AmbiguousTableFactoryException.java
 create mode 100644 flink-table/flink-table-common/src/main/java/org/apache/flink/table/factories/NoMatchingTableFactoryException.java
 rename flink-table/{flink-table-common/src/main/java/org/apache/flink/table/api => flink-table-planner/src/main/java/org/apache/flink/table/planner/expressions}/UnresolvedException.java (90%)