You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by lz...@apache.org on 2020/05/26 06:29:31 UTC

[flink] branch master updated (ec0288c -> 808c87d)

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from ec0288c  [FLINK-17889][hive] Hive can not work with filesystem connector
     add e215365  [FLINK-17896][hive] HiveCatalog can work with new table factory because of is_generic
     add babefb5  [FLINK-17867][hive][test] Add hdfs dependency to hive-3.1.1 test
     add dc32661  [FLINK-17456][hive][test] Update hive connector tests to execute DDL & DML via TableEnvironment
     add 808c87d  [hotfix] Remove generic row for HiveTableFactory

No new revisions were added by this update.

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