Enhance batch size calculation

Signed-off-by: Ansari, Mujammil <[email protected]>
heremaps · Dec 9, 2024 · a98e02f · a98e02f
1 parent d04b850
commit a98e02f
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/...rvice/src/main/java/com/here/xyz/hub/connectors/statistics/StorageStatisticsProvider.java b/...rvice/src/main/java/com/here/xyz/hub/connectors/statistics/StorageStatisticsProvider.java
@@ -118,10 +118,9 @@ private static Future<StorageStatistics> fetchFromStorage(Marker marker, String
 
   private static Future<StorageStatistics> fetchFromStorage(Marker marker, Connector storage, List<String> spaceIds) {
 
-    int concurrentRequests = spaceIds.size() > MAX_CONCURRENT_REQUEST_COUNT * MAX_SPACE_BATCH_SIZE ? MAX_CONCURRENT_REQUEST_COUNT
-            : spaceIds.size() / MAX_SPACE_BATCH_SIZE;
+    int targetSize = spaceIds.size() > MAX_CONCURRENT_REQUEST_COUNT * MAX_SPACE_BATCH_SIZE
+            ? (int) Math.ceil((double) spaceIds.size() / MAX_CONCURRENT_REQUEST_COUNT) : MAX_SPACE_BATCH_SIZE;
 
-    int targetSize = (int) Math.ceil((float) spaceIds.size() / (float) concurrentRequests);
     return CompositeFuture.all(Lists.partition(spaceIds, targetSize)
             .stream()
             .map(batchSpaceIds -> fetchFromStorageInBatches(marker, storage, batchSpaceIds))