diff --git ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java index fd64056..fa87b7b 100644 --- ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java +++ ql/src/java/org/apache/hadoop/hive/ql/exec/Utilities.java @@ -2858,6 +2858,11 @@ public static int estimateReducers(long totalInputFileSize, long bytesPerReducer reducers = reducersPowerTwo; } } + + if ((reducers % 31) == 0) { + reducers += 1; + } + return reducers; }