@@ -51,8 +51,6 @@ public abstract class ShardFollowNodeTask extends AllocatedPersistentTask {
5151
5252 private final String leaderIndex ;
5353 private final ShardFollowTask params ;
54- private final TimeValue pollTimeout ;
55- private final TimeValue maxRetryDelay ;
5654 private final BiConsumer <TimeValue , Runnable > scheduler ;
5755 private final LongSupplier relativeTimeProvider ;
5856
@@ -83,8 +81,6 @@ public abstract class ShardFollowNodeTask extends AllocatedPersistentTask {
8381 this .params = params ;
8482 this .scheduler = scheduler ;
8583 this .relativeTimeProvider = relativeTimeProvider ;
86- this .pollTimeout = params .getPollTimeout ();
87- this .maxRetryDelay = params .getMaxRetryDelay ();
8884 /*
8985 * We keep track of the most recent fetch exceptions, with the number of exceptions that we track equal to the maximum number of
9086 * concurrent fetches. For each failed fetch, we track the from sequence number associated with the request, and we clear the entry
@@ -361,7 +357,7 @@ private void handleFailure(Exception e, AtomicInteger retryCounter, Runnable tas
361357 int currentRetry = retryCounter .incrementAndGet ();
362358 LOGGER .debug (new ParameterizedMessage ("{} error during follow shard task, retrying [{}]" ,
363359 params .getFollowShardId (), currentRetry ), e );
364- long delay = computeDelay (currentRetry , maxRetryDelay .getMillis ());
360+ long delay = computeDelay (currentRetry , params . getPollTimeout () .getMillis ());
365361 scheduler .accept (TimeValue .timeValueMillis (delay ), task );
366362 } else {
367363 markAsFailed (e );
0 commit comments