[flink] branch master updated (ef3dd92 -> 08793a9)

[bl...@apache.org]

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

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


    from ef3dd92  [FLINK-14371][tests] Enable ClassLoaderITCase to pass with NG scheduler
     add 08793a9  [FLINK-14418][hive] Create HiveModule to provide Hive built-in functions

No new revisions were added by this update.

Summary of changes:
 .../flink/table/catalog/hive/HiveCatalog.java      |  2 +-
 .../flink/table/catalog/hive/client/HiveShim.java  | 12 +++
 .../table/catalog/hive/client/HiveShimV100.java    | 17 +++++
 .../table/catalog/hive/client/HiveShimV120.java    | 53 +++++++++++++
 .../factories/HiveFunctionDefinitionFactory.java   | 32 ++++----
 .../table/functions/hive/HiveGenericUDAF.java      | 15 ++--
 .../apache/flink/table/module/hive/HiveModule.java | 37 +++++----
 .../apache/flink/table/HiveVersionTestUtil.java}   | 18 ++---
 .../table/functions/hive/HiveGenericUDAFTest.java  |  2 +-
 .../table/functions/hive/HiveGenericUDFTest.java   |  4 +-
 .../flink/table/module/hive/HiveModuleTest.java    | 89 ++++++++++++++++++++++
 .../src/test/resources/csv/test2.csv               |  3 +
 12 files changed, 226 insertions(+), 58 deletions(-)
 copy flink-table/flink-table-common/src/main/java/org/apache/flink/table/module/CoreModule.java => flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/module/hive/HiveModule.java (52%)
 copy flink-connectors/{flink-connector-kinesis/src/test/java/org/apache/flink/streaming/connectors/kinesis/model/SentinelSequenceNumberTest.java => flink-connector-hive/src/test/java/org/apache/flink/table/HiveVersionTestUtil.java} (64%)
 create mode 100644 flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/module/hive/HiveModuleTest.java
 create mode 100644 flink-connectors/flink-connector-hive/src/test/resources/csv/test2.csv