DRILL-2916: Correctly set minimum per fragment in AssignmentCreator
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/store/schedule/AssignmentCreator.java b/exec/java-exec/src/main/java/org/apache/drill/exec/store/schedule/AssignmentCreator.java
index bfc104f..1f4d8cb 100644
--- a/exec/java-exec/src/main/java/org/apache/drill/exec/store/schedule/AssignmentCreator.java
+++ b/exec/java-exec/src/main/java/org/apache/drill/exec/store/schedule/AssignmentCreator.java
@@ -247,14 +247,14 @@
FragIteratorWrapper wrapper = new FragIteratorWrapper();
wrapper.iter = Iterators.cycle(mmap.get(endpoint));
wrapper.maxCount = maxWork * mmap.get(endpoint).size();
- wrapper.minCount = Math.max((maxWork - 1) * mmap.get(endpoint).size(), 1);
+ wrapper.minCount = Math.max(maxWork - 1, 1) * mmap.get(endpoint).size();
map.put(endpoint, wrapper);
}
return map;
}
/**
- * A struct that holds an fragment iterator and keeps track of how many units have been assigned, as well as the maximum
+ * A struct that holds a fragment iterator and keeps track of how many units have been assigned, as well as the maximum
* number of assignment it will accept
*/
private static class FragIteratorWrapper {
