diff --git a/geo-analyzer/src/main/java/au/gov/amsa/geo/distance/DistanceTravelledCalculator.java b/geo-analyzer/src/main/java/au/gov/amsa/geo/distance/DistanceTravelledCalculator.java
index <HASH>..<HASH> 100644
--- a/geo-analyzer/src/main/java/au/gov/amsa/geo/distance/DistanceTravelledCalculator.java
+++ b/geo-analyzer/src/main/java/au/gov/amsa/geo/distance/DistanceTravelledCalculator.java
@@ -70,7 +70,7 @@ public class DistanceTravelledCalculator {
                 .buffer(Math.max(
                         1,
                         (int) Math.round(Math.ceil(numFiles
-                                / Runtime.getRuntime().availableProcessors())) - 1))
+                                / Runtime.getRuntime().availableProcessors()))))
                 .flatMap(fileList ->
                 // extract fixes from each file
                         Observable
use all available processors for distance travelled calculation