Merge pull request #112 from mminella/BATCH-1757

BATCH-1757: MinMaxPartitioner sets incorrect max value
This commit is contained in:
Michael Minella
2013-02-05 07:41:59 -08:00

View File

@@ -35,7 +35,7 @@ public class MinMaxPartitioner extends SimplePartitioner {
int i = 0;
for (ExecutionContext context : partition.values()) {
int min = (i++)*range;
int max = Math.min(total, (min+1)*range);
int max = Math.min(total, i * range);
context.putInt("min", min);
context.putInt("max", max);
}