Core: Log retry sleep time (#11413)

apache · Oct 31, 2024 · 1d4df34 · 1d4df34
1 parent ea61ee4
commit 1d4df34
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/core/src/main/java/org/apache/iceberg/util/Tasks.java b/core/src/main/java/org/apache/iceberg/util/Tasks.java
@@ -454,11 +454,13 @@ private <E extends Exception> void runTaskWithRetry(Task<I, E> task, I item) thr
                   Math.min(
                       minSleepTimeMs * Math.pow(scaleFactor, attempt - 1), (double) maxSleepTimeMs);
           int jitter = ThreadLocalRandom.current().nextInt(Math.max(1, (int) (delayMs * 0.1)));
+          int sleepTimeMs = delayMs + jitter;
 
-          LOG.warn("Retrying task after failure: {}", e.getMessage(), e);
+          LOG.warn(
+              "Retrying task after failure: sleepTimeMs={} {}", sleepTimeMs, e.getMessage(), e);
 
           try {
-            TimeUnit.MILLISECONDS.sleep(delayMs + jitter);
+            TimeUnit.MILLISECONDS.sleep(sleepTimeMs);
           } catch (InterruptedException ie) {
             Thread.currentThread().interrupt();
             throw new RuntimeException(ie);