diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/FetchOperator.java ql/src/java/org/apache/hadoop/hive/ql/exec/FetchOperator.java index dfd4524..75711e7 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/FetchOperator.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/FetchOperator.java @@ -367,6 +367,12 @@ private void getNextPath() throws Exception { job.set("mapred.input.dir", org.apache.hadoop.util.StringUtils.escapeString(currPath .toString())); + // Fetch operator is not vectorized and as such turn vectorization flag off so that + // non-vectorized record reader is created below. + if (HiveConf.getBoolVar(job, HiveConf.ConfVars.HIVE_VECTORIZATION_ENABLED)) { + HiveConf.setBoolVar(job, HiveConf.ConfVars.HIVE_VECTORIZATION_ENABLED, false); + } + PartitionDesc partDesc; if (currTbl == null) { partDesc = currPart;