com.aliyun.odps.storage.internal.retry

Class InfiniteExponentialBackoffPolicy

java.lang.Object

com.aliyun.odps.storage.internal.retry.InfiniteExponentialBackoffPolicy

All Implemented Interfaces:

RetryPolicy

public class InfiniteExponentialBackoffPolicy
extends Object
implements RetryPolicy

A retry policy with infinite exponential backoff and jitter.

This policy retries indefinitely with exponential backoff up to a maximum wait time, and adds random jitter to prevent thundering herd problems when multiple clients retry simultaneously.

This policy is suitable for transient errors like rate limiting (429) or temporary service unavailability.

Wait time calculation: base_wait = 2^(attempt-1) seconds (capped at 64 seconds) With jitter: final_wait = base_wait + (base_wait * 0.1 * random) Max wait time: 64 seconds

Field Summary

Fields

Modifier and Type	Field and Description
static InfiniteExponentialBackoffPolicy	INSTANCE

Method Summary

Modifier and Type	Method and Description
long	getRetryWaitTime(int attempt) Calculates the wait time before the next retry attempt.
boolean	shouldRetry(Exception e, int attempt) Determines whether an operation should be retried based on the exception and attempt count.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.aliyun.odps.storage.internal.retry.RetryPolicy

waitForNextRetry

Field Detail

INSTANCE

public static final InfiniteExponentialBackoffPolicy INSTANCE

Method Detail

shouldRetry

public boolean shouldRetry(Exception e,
                           int attempt)

Description copied from interface: RetryPolicy

Determines whether an operation should be retried based on the exception and attempt count.

Specified by:

shouldRetry in interface RetryPolicy

Parameters:

e - The exception that occurred

attempt - The current attempt number (1-based)

Returns:

true if the operation should be retried, false otherwise

getRetryWaitTime

public long getRetryWaitTime(int attempt)

Description copied from interface: RetryPolicy

Calculates the wait time before the next retry attempt.

Specified by:

getRetryWaitTime in interface RetryPolicy

Parameters:

attempt - The current attempt number (1-based)

Returns:

The wait time in milliseconds