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..c54ea54 100644 --- ql/src/java/org/apache/hadoop/hive/ql/parse/GenTezUtils.java +++ ql/src/java/org/apache/hadoop/hive/ql/parse/GenTezUtils.java @@ -120,7 +120,8 @@ 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 > maxReducers) ? maxReducers : + maxPartition); reduceWork.setMinReduceTasks(minPartition); reduceWork.setMaxReduceTasks(maxPartition);