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..d568893 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,10 @@ 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. + HiveConf.setBoolVar(job, HiveConf.ConfVars.HIVE_VECTORIZATION_ENABLED, false); + PartitionDesc partDesc; if (currTbl == null) { partDesc = currPart;