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/06/09 04:04:35 UTC
[flink] branch release-1.11 updated: [FLINK-16291][hive] Ban count
from HiveModule
This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a commit to branch release-1.11
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.11 by this push:
new 513ac5a [FLINK-16291][hive] Ban count from HiveModule
513ac5a is described below
commit 513ac5ae8d4fc1e679a7faf07a7d020f073a09fc
Author: Rui Li <li...@apache.org>
AuthorDate: Tue Jun 9 12:03:23 2020 +0800
[FLINK-16291][hive] Ban count from HiveModule
This closes #12382
---
.../java/org/apache/flink/table/module/hive/HiveModule.java | 2 +-
.../org/apache/flink/table/module/hive/HiveModuleTest.java | 12 ++++++------
2 files changed, 7 insertions(+), 7 deletions(-)
diff --git a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/module/hive/HiveModule.java b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/module/hive/HiveModule.java
index e34965b..12fc5f1 100644
--- a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/module/hive/HiveModule.java
+++ b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/module/hive/HiveModule.java
@@ -44,7 +44,7 @@ public class HiveModule implements Module {
// a set of functions that shouldn't be overridden by HiveModule
@VisibleForTesting
static final Set<String> BUILT_IN_FUNC_BLACKLIST = Collections.unmodifiableSet(new HashSet<>(
- Arrays.asList("dense_rank", "first_value", "lag", "last_value", "lead", "rank", "row_number",
+ Arrays.asList("count", "dense_rank", "first_value", "lag", "last_value", "lead", "rank", "row_number",
"hop", "hop_end", "hop_proctime", "hop_rowtime", "hop_start",
"session", "session_end", "session_proctime", "session_rowtime", "session_start",
"tumble", "tumble_end", "tumble_proctime", "tumble_rowtime", "tumble_start")));
diff --git a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/module/hive/HiveModuleTest.java b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/module/hive/HiveModuleTest.java
index 65cbda51..374984a 100644
--- a/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/module/hive/HiveModuleTest.java
+++ b/flink-connectors/flink-connector-hive/src/test/java/org/apache/flink/table/module/hive/HiveModuleTest.java
@@ -62,22 +62,22 @@ public class HiveModuleTest {
switch (hiveVersion) {
case HIVE_VERSION_V1_2_0:
- assertEquals(232, hiveModule.listFunctions().size());
+ assertEquals(231, hiveModule.listFunctions().size());
break;
case HIVE_VERSION_V2_0_0:
- assertEquals(236, hiveModule.listFunctions().size());
+ assertEquals(235, hiveModule.listFunctions().size());
break;
case HIVE_VERSION_V2_1_1:
- assertEquals(246, hiveModule.listFunctions().size());
+ assertEquals(245, hiveModule.listFunctions().size());
break;
case HIVE_VERSION_V2_2_0:
- assertEquals(262, hiveModule.listFunctions().size());
+ assertEquals(261, hiveModule.listFunctions().size());
break;
case HIVE_VERSION_V2_3_4:
- assertEquals(280, hiveModule.listFunctions().size());
+ assertEquals(279, hiveModule.listFunctions().size());
break;
case HIVE_VERSION_V3_1_1:
- assertEquals(299, hiveModule.listFunctions().size());
+ assertEquals(298, hiveModule.listFunctions().size());
break;
}
}