Revert to be safe

apache · Sep 12, 2024 · 97ed25f · 97ed25f
1 parent 129f937
commit 97ed25f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/core/src/main/java/org/apache/iceberg/SnapshotProducer.java b/core/src/main/java/org/apache/iceberg/SnapshotProducer.java
@@ -640,8 +640,8 @@ private static <T> List<List<T>> divide(List<T> list, int groupCount) {
    */
   @VisibleForTesting
   static int manifestWriterCount(int workerPoolSize, int fileCount) {
-    int limit = Math.max(1, IntMath.divide(fileCount, MIN_FILE_GROUP_SIZE, RoundingMode.HALF_UP));
-    return Math.min(workerPoolSize, limit);
+    int limit = IntMath.divide(fileCount, MIN_FILE_GROUP_SIZE, RoundingMode.HALF_UP);
+    return Math.max(1, Math.min(workerPoolSize, limit));
   }
 
   private static ManifestFile addMetadata(TableOperations ops, ManifestFile manifest) {