(iceberg) branch main updated: Core: Skip testAddManyFilesWithConsistentOrdering if WORKER_THREAD_POOL_SIZE < 3 (#16506)

[stevenwu]

This is an automated email from the ASF dual-hosted git repository.

stevenzwu pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iceberg.git


The following commit(s) were added to refs/heads/main by this push:
     new 99e451acf3 Core: Skip testAddManyFilesWithConsistentOrdering if 
WORKER_THREAD_POOL_SIZE < 3 (#16506)
99e451acf3 is described below

commit 99e451acf38266c5eed9482c7feeaf20914620d5
Author: Yuya Ebihara <eby...@gmail.com>
AuthorDate: Sat May 23 07:14:10 2026 +0900

    Core: Skip testAddManyFilesWithConsistentOrdering if 
WORKER_THREAD_POOL_SIZE < 3 (#16506)
---
 core/src/test/java/org/apache/iceberg/TestMergeAppend.java | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/core/src/test/java/org/apache/iceberg/TestMergeAppend.java 
b/core/src/test/java/org/apache/iceberg/TestMergeAppend.java
index b7700d7ce7..c5f3d88f46 100644
--- a/core/src/test/java/org/apache/iceberg/TestMergeAppend.java
+++ b/core/src/test/java/org/apache/iceberg/TestMergeAppend.java
@@ -41,6 +41,7 @@ import 
org.apache.iceberg.relocated.com.google.common.collect.Iterables;
 import org.apache.iceberg.relocated.com.google.common.collect.Lists;
 import org.apache.iceberg.relocated.com.google.common.collect.Sets;
 import org.apache.iceberg.types.Types;
+import org.apache.iceberg.util.ThreadPools;
 import org.junit.jupiter.api.TestTemplate;
 import org.junit.jupiter.api.extension.ExtendWith;
 
@@ -90,6 +91,11 @@ public class TestMergeAppend extends TestBase {
     assertThat(listManifestFiles()).as("Table should start empty").isEmpty();
 
     int multiplier = 3;
+    assumeThat(ThreadPools.WORKER_THREAD_POOL_SIZE)
+        .as(
+            "Worker thread pool size should be at least 3 to test manifest 
file ordering with multiple threads")
+        .isGreaterThanOrEqualTo(multiplier);
+
     int groupSize = SnapshotProducer.MIN_FILE_GROUP_SIZE;
     List<DataFile> dataFiles = Lists.newArrayList();