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 27d7276..4919285 100644 --- ql/src/java/org/apache/hadoop/hive/ql/parse/GenTezUtils.java +++ ql/src/java/org/apache/hadoop/hive/ql/parse/GenTezUtils.java @@ -121,6 +121,7 @@ public static ReduceWork createReduceWork( // max we allow tez to pick int maxPartition = (int) (reduceSink.getConf().getNumReducers() * maxPartitionFactor); maxPartition = (maxPartition > maxReducers) ? maxReducers : maxPartition; + maxPartition = Math.max(1, maxPartition); reduceWork.setMinReduceTasks(minPartition); reduceWork.setMaxReduceTasks(maxPartition);