From 1d9b9aa63415091ccb1475ee85f92b55610afb9e Mon Sep 17 00:00:00 2001 From: Vova Kolmakov Date: Thu, 11 Jun 2026 16:48:53 +0700 Subject: [PATCH] Core: Fix flaky TestHadoopCommits.testConcurrentFastAppends Co-Authored-By: Claude Opus 4.8 (1M context) --- .../java/org/apache/iceberg/hadoop/TestHadoopCommits.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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,