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 9fd6ecf [FLINK-22180][coordination] Only reclaim slots if job is
removed
add 5b9e788 [FLINK-21660][hive] Stop using is_generic to differentiate
hive and flink tables (#15155)
No new revisions were added by this update.
Summary of changes:
.../connectors/hive/HiveDynamicTableFactory.java | 46 +---
.../flink/connectors/hive/HiveTableFactory.java | 20 +-
.../flink/table/catalog/hive/HiveCatalog.java | 252 ++++++++++++---------
.../flink/table/catalog/hive/HiveDatabaseUtil.java | 105 ---------
.../table/catalog/hive/util/HiveTableUtil.java | 40 ++--
.../delegation/hive/DDLOperationConverter.java | 12 +-
.../flink/connectors/hive/HiveDialectITCase.java | 4 -
.../connectors/hive/HiveTableFactoryTest.java | 7 +-
.../catalog/hive/HiveCatalogDataTypeTest.java | 5 +-
.../hive/HiveCatalogGenericMetadataTest.java | 19 +-
.../catalog/hive/HiveCatalogHiveMetadataTest.java | 29 +--
.../table/catalog/hive/HiveCatalogITCase.java | 25 ++
.../flink/table/catalog/hive/HiveCatalogTest.java | 12 +-
flink-python/pyflink/table/tests/test_catalog.py | 6 +-
.../table/client/gateway/local/DependencyTest.java | 5 +-
.../sql/parser/hive/ddl/SqlCreateHiveDatabase.java | 5 -
.../sql/parser/hive/ddl/SqlCreateHiveTable.java | 8 +-
.../sql/parser/hive/ddl/SqlCreateHiveView.java | 6 +-
.../flink/table/catalog/CatalogDatabaseImpl.java | 5 +
.../flink/table/catalog/CatalogTableBuilder.java | 7 -
.../flink/table/catalog/CatalogTableImpl.java | 1 -
.../table/catalog/GenericInMemoryCatalog.java | 4 +-
.../flink/table/catalog/CatalogTestBase.java | 6 +-
.../flink/table/catalog/CatalogDatabase.java | 7 +
.../apache/flink/table/catalog/CatalogTest.java | 8 +-
.../flink/table/catalog/CatalogTestUtil.java | 27 +--
26 files changed, 286 insertions(+), 385 deletions(-)
delete mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/HiveDatabaseUtil.java
