This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 643f4a1 [FLINK-17889][hive] Hive can not work with filesystem
connector
new da1ccb9 [FLINK-17896][hive] HiveCatalog can work with new table
factory because of is_generic
new 52b7e87 [FLINK-17867][hive][test] Add hdfs dependency to hive-3.1.1
test
new d836cd3 [FLINK-17456][hive][test] Update hive connector tests to
execute DDL & DML via TableEnvironment
new 2f92386 [hotfix] Remove generic row for HiveTableFactory
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
flink-connectors/flink-connector-hive/pom.xml | 8 +
.../connectors/hive/HiveDynamicTableFactory.java | 88 ++++++++
.../flink/connectors/hive/HiveTableFactory.java | 5 +-
.../flink/table/catalog/hive/HiveCatalog.java | 7 +
.../flink/connectors/hive/HiveLookupJoinTest.java | 2 +-
.../flink/connectors/hive/HiveTableSinkTest.java | 12 +-
.../flink/connectors/hive/HiveTableSourceTest.java | 132 ++++++------
.../connectors/hive/TableEnvHiveConnectorTest.java | 232 +++++++++++----------
.../table/catalog/hive/HiveCatalogITCase.java | 44 +++-
.../catalog/hive/HiveCatalogUseBlinkITCase.java | 29 ++-
.../flink/table/catalog/hive/HiveTestUtils.java | 12 ++
11 files changed, 355 insertions(+), 216 deletions(-)
create mode 100644
flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/connectors/hive/HiveDynamicTableFactory.java
