diff --git a/core/src/test/java/org/apache/iceberg/hadoop/TestHadoopCommits.java b/core/src/test/java/org/apache/iceberg/hadoop/TestHadoopCommits.java index 818b16da24ec..be96b959ead9 100644 --- a/core/src/test/java/org/apache/iceberg/hadoop/TestHadoopCommits.java +++ b/core/src/test/java/org/apache/iceberg/hadoop/TestHadoopCommits.java @@ -426,8 +426,10 @@ public void testConcurrentFastAppends(@TempDir File dir) throws Exception { SCHEMA, SPEC, ImmutableMap.of( + // Use a high retry count so no committer exhausts its retries under the forced + // lock-step contention below (matches Test{Jdbc,Hive}TableConcurrency). COMMIT_NUM_RETRIES, - String.valueOf(threadsCount), + "20", COMMIT_MIN_RETRY_WAIT_MS, "10", COMMIT_MAX_RETRY_WAIT_MS,