diff --git ql/src/java/org/apache/hadoop/hive/ql/parse/GenTezUtils.java ql/src/java/org/apache/hadoop/hive/ql/parse/GenTezUtils.java index d5a2eca..fc349ff 100644 --- ql/src/java/org/apache/hadoop/hive/ql/parse/GenTezUtils.java +++ ql/src/java/org/apache/hadoop/hive/ql/parse/GenTezUtils.java @@ -106,7 +106,10 @@ public static ReduceWork createReduceWork( reduceWork.setNumReduceTasks(reduceSink.getConf().getNumReducers()); - if (isAutoReduceParallelism && reduceSink.getConf().getReducerTraits().contains(AUTOPARALLEL)) { + final float minReducerParallelism = reduceSink.getConf().getNumReducers() * minPartitionFactor; + + if (isAutoReduceParallelism && reduceSink.getConf().getReducerTraits().contains(AUTOPARALLEL) + && minReducerParallelism >= 1.0) { reduceWork.setAutoReduceParallelism(true); // configured limit for reducers