You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2019/08/29 20:44:58 UTC
[flink] branch master updated: [FLINK-13147][hive] Deduplicate
conditions
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push:
new b941ea8 [FLINK-13147][hive] Deduplicate conditions
b941ea8 is described below
commit b941ea8af517238f73299923c491175a8e88fc93
Author: tianchen92 <ni...@alibaba-inc.com>
AuthorDate: Fri Aug 30 04:44:45 2019 +0800
[FLINK-13147][hive] Deduplicate conditions
---
.../java/org/apache/flink/table/catalog/hive/util/HiveStatsUtil.java | 1 -
1 file changed, 1 deletion(-)
diff --git a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/util/HiveStatsUtil.java b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/util/HiveStatsUtil.java
index 97bfa56..232b5f6 100644
--- a/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/util/HiveStatsUtil.java
+++ b/flink-connectors/flink-connector-hive/src/main/java/org/apache/flink/table/catalog/hive/util/HiveStatsUtil.java
@@ -229,7 +229,6 @@ public class HiveStatsUtil {
return ColumnStatisticsData.dateStats(dateStats);
}
} else if (type.equals(LogicalTypeRoot.VARBINARY)
- || type.equals(LogicalTypeRoot.BINARY)
|| type.equals(LogicalTypeRoot.BINARY)) {
if (colStat instanceof CatalogColumnStatisticsDataBinary) {
CatalogColumnStatisticsDataBinary binaryColumnStatsData = (CatalogColumnStatisticsDataBinary) colStat;