Skip to content

Commit

Permalink
Remove unused variable in FaultTolerantChunkProcessor
Browse files Browse the repository at this point in the history
This commit removes the count variable which is
incremented but never queried.
  • Loading branch information
fmbenhassine committed Sep 9, 2021
1 parent 7067dcb commit dacf5bc
Showing 1 changed file with 1 addition and 4 deletions.
Original file line number Diff line number Diff line change
@@ -1,5 +1,5 @@
/*
* Copyright 2006-2020 the original author or authors.
* Copyright 2006-2021 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
Expand All @@ -20,7 +20,6 @@
import java.util.Collections;
import java.util.Iterator;
import java.util.List;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicReference;

import io.micrometer.core.instrument.Tag;
Expand Down Expand Up @@ -213,7 +212,6 @@ protected Chunk<O> transform(final StepContribution contribution, Chunk<I> input
final UserData<O> data = (UserData<O>) inputs.getUserData();
final Chunk<O> cache = data.getOutputs();
final Iterator<O> cacheIterator = cache.isEmpty() ? null : new ArrayList<>(cache.getItems()).iterator();
final AtomicInteger count = new AtomicInteger(0);

// final int scanLimit = processorTransactional && data.scanning() ? 1 :
// 0;
Expand All @@ -230,7 +228,6 @@ public O doWithRetry(RetryContext context) throws Exception {
String status = BatchMetrics.STATUS_SUCCESS;
O output = null;
try {
count.incrementAndGet();
O cached = (cacheIterator != null && cacheIterator.hasNext()) ? cacheIterator.next() : null;
if (cached != null && !processorTransactional) {
output = cached;
Expand Down

0 comments on commit dacf5bc

Please sign in to comment.