(iceberg) branch main updated: Core: Include attempt and maxAttempts in Tasks retry log (#18664)

[huaxingao]

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

huaxingao 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 34927ff68e Core: Include attempt and maxAttempts in Tasks retry log 
(#18664)
34927ff68e is described below

commit 34927ff68e3e468f4f81ea4305b54de95562efe1
Author: Prathamesh Kulkarni <prathameshk2...@gmail.com>
AuthorDate: Tue Oct 27 11:56:06 2026 -0700

    Core: Include attempt and maxAttempts in Tasks retry log (#18664)
    
    Co-authored-by: Claude Code <nore...@anthropic.com>
---
 core/src/main/java/org/apache/iceberg/util/Tasks.java | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)

diff --git a/core/src/main/java/org/apache/iceberg/util/Tasks.java 
b/core/src/main/java/org/apache/iceberg/util/Tasks.java
index 638736c45e..df28528ba3 100644
--- a/core/src/main/java/org/apache/iceberg/util/Tasks.java
+++ b/core/src/main/java/org/apache/iceberg/util/Tasks.java
@@ -467,7 +467,12 @@ public class Tasks {
           int sleepTimeMs = delayMs + jitter;
 
           LOG.warn(
-              "Retrying task after failure: sleepTimeMs={} {}", sleepTimeMs, 
e.getMessage(), e);
+              "Retrying task after failure: attempt={} maxAttempts={} 
sleepTimeMs={} {}",
+              attempt,
+              maxAttempts,
+              sleepTimeMs,
+              e.getMessage(),
+              e);
 
           try {
             TimeUnit.MILLISECONDS.sleep(sleepTimeMs);