From 38def7cb1a3a6e28894fd3ecb14cf69d7ec99cd5 Mon Sep 17 00:00:00 2001 From: Daoyuan Wang Date: Thu, 27 Aug 2020 15:39:20 +0800 Subject: [PATCH] fix get filter referenced columns --- .../com/mongodb/hadoop/hive/input/HiveMongoInputFormat.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/hive/src/main/java/com/mongodb/hadoop/hive/input/HiveMongoInputFormat.java b/hive/src/main/java/com/mongodb/hadoop/hive/input/HiveMongoInputFormat.java index eb003498..155895db 100644 --- a/hive/src/main/java/com/mongodb/hadoop/hive/input/HiveMongoInputFormat.java +++ b/hive/src/main/java/com/mongodb/hadoop/hive/input/HiveMongoInputFormat.java @@ -43,6 +43,7 @@ import org.apache.hadoop.hive.ql.udf.generic.GenericUDFOPEqualOrLessThan; import org.apache.hadoop.hive.ql.udf.generic.GenericUDFOPGreaterThan; import org.apache.hadoop.hive.ql.udf.generic.GenericUDFOPLessThan; +import org.apache.hadoop.hive.serde.serdeConstants; import org.apache.hadoop.hive.serde2.ColumnProjectionUtils; import org.apache.hadoop.io.Text; import org.apache.hadoop.mapred.FileSplit; @@ -136,8 +137,7 @@ DBObject getFilter( IndexPredicateAnalyzer.createAnalyzer(false); // Allow all column names. - String columnNamesStr = - conf.get(ColumnProjectionUtils.READ_COLUMN_NAMES_CONF_STR); + String columnNamesStr = conf.get(serdeConstants.LIST_COLUMNS); String[] columnNames = StringUtils.split(columnNamesStr, '\\', StringUtils.COMMA); for (String colName : columnNames) {