BATCH-1757: Fixed max calculation
This commit is contained in:
@@ -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);
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user