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