This is an automated email from the ASF dual-hosted git repository.
singhpk234 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 a50c2d920a Core: Rename MAX_ATTEMPTS to MAX_RETRIES in RESTTableScan
(#15627)
a50c2d920a is described below
commit a50c2d920aadbb79f978bac10d1271bc4aa63a1a
Author: Prashant Singh <[email protected]>
AuthorDate: Fri Mar 13 15:53:03 2026 -0700
Core: Rename MAX_ATTEMPTS to MAX_RETRIES in RESTTableScan (#15627)
Co-authored-by: Prashant Singh <[email protected]>
---
core/src/main/java/org/apache/iceberg/rest/RESTTableScan.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/core/src/main/java/org/apache/iceberg/rest/RESTTableScan.java
b/core/src/main/java/org/apache/iceberg/rest/RESTTableScan.java
index f533f2c87f..a78628ed87 100644
--- a/core/src/main/java/org/apache/iceberg/rest/RESTTableScan.java
+++ b/core/src/main/java/org/apache/iceberg/rest/RESTTableScan.java
@@ -55,7 +55,7 @@ class RESTTableScan extends DataTableScan {
private static final Logger LOG =
LoggerFactory.getLogger(RESTTableScan.class);
private static final long MIN_SLEEP_MS = 1000; // Initial delay
private static final long MAX_SLEEP_MS = 60 * 1000; // Max backoff delay (1
minute)
- private static final int MAX_ATTEMPTS = 10; // Max number of poll checks
+ private static final int MAX_RETRIES = 10; // Max number of poll retries
private static final long MAX_WAIT_TIME_MS = 5 * 60 * 1000; // Total maximum
duration (5 minutes)
private static final double SCALE_FACTOR = 2.0; // Exponential scale factor
private static final String DEFAULT_FILE_IO_IMPL =
"org.apache.iceberg.io.ResolvingFileIO";
@@ -229,7 +229,7 @@ class RESTTableScan extends DataTableScan {
AtomicReference<FetchPlanningResultResponse> result = new
AtomicReference<>();
Tasks.foreach(planId)
.exponentialBackoff(MIN_SLEEP_MS, MAX_SLEEP_MS, MAX_WAIT_TIME_MS,
SCALE_FACTOR)
- .retry(MAX_ATTEMPTS)
+ .retry(MAX_RETRIES)
.onlyRetryOn(NotCompleteException.class)
.onFailure(
(id, err) -> {
