honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

removed unused fields

This commit is contained in:
Martijn van Groningen 2018-09-20 08:55:57 +02:00
parent 3ca53437a2
commit 384ce58535
No known key found for this signature in database
GPG Key ID: AB236F4FCF2AF12A
1 changed files with 1 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
x-pack/plugin/ccr/src/main/java/org/elasticsearch/xpack/ccr/action/ShardFollowNodeTask.java
View File

@ -51,8 +51,6 @@ public abstract class ShardFollowNodeTask extends AllocatedPersistentTask {
private final String leaderIndex; private final String leaderIndex;
private final ShardFollowTask params; private final ShardFollowTask params;
private final TimeValue pollTimeout;
private final TimeValue maxRetryDelay;
private final BiConsumer<TimeValue, Runnable> scheduler; private final BiConsumer<TimeValue, Runnable> scheduler;
private final LongSupplier relativeTimeProvider; private final LongSupplier relativeTimeProvider;
@ -83,8 +81,6 @@ public abstract class ShardFollowNodeTask extends AllocatedPersistentTask {
this.params = params; this.params = params;
this.scheduler = scheduler; this.scheduler = scheduler;
this.relativeTimeProvider = relativeTimeProvider; this.relativeTimeProvider = relativeTimeProvider;
this.pollTimeout = params.getPollTimeout();
this.maxRetryDelay = params.getMaxRetryDelay();
/* /*
* We keep track of the most recent fetch exceptions, with the number of exceptions that we track equal to the maximum number of * We keep track of the most recent fetch exceptions, with the number of exceptions that we track equal to the maximum number of
* concurrent fetches. For each failed fetch, we track the from sequence number associated with the request, and we clear the entry * 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 @@ public abstract class ShardFollowNodeTask extends AllocatedPersistentTask {
int currentRetry = retryCounter.incrementAndGet(); int currentRetry = retryCounter.incrementAndGet();
LOGGER.debug(new ParameterizedMessage("{} error during follow shard task, retrying [{}]", LOGGER.debug(new ParameterizedMessage("{} error during follow shard task, retrying [{}]",
params.getFollowShardId(), currentRetry), e); params.getFollowShardId(), currentRetry), e);
long delay = computeDelay(currentRetry, maxRetryDelay.getMillis()); long delay = computeDelay(currentRetry, params.getPollTimeout().getMillis());
scheduler.accept(TimeValue.timeValueMillis(delay), task); scheduler.accept(TimeValue.timeValueMillis(delay), task);
} else { } else {
markAsFailed(e); markAsFailed(e);