fix copy/paste compile issue
This commit is contained in:
@@ -234,11 +234,6 @@ public class AcsReconcileService implements DisposableBean {
|
|||||||
CompositeFuture<Void> future = new CompositeFuture<>();
|
CompositeFuture<Void> future = new CompositeFuture<>();
|
||||||
ThrottledThreadPoolExecutor executor = this.getExecutor();
|
ThrottledThreadPoolExecutor executor = this.getExecutor();
|
||||||
|
|
||||||
ThrottledThreadPoolExecutor executor = this.executorManager.createThrottled(
|
|
||||||
"solr-reconcile",
|
|
||||||
this.concurrency, this.concurrency, this.concurrentQueueSize,
|
|
||||||
1L, TimeUnit.MINUTES);
|
|
||||||
|
|
||||||
for (long _nodeDbId = fromDbId; _nodeDbId < toDbId; _nodeDbId++) {
|
for (long _nodeDbId = fromDbId; _nodeDbId < toDbId; _nodeDbId++) {
|
||||||
final long nodeDbId = _nodeDbId;
|
final long nodeDbId = _nodeDbId;
|
||||||
this.logger.trace("Attempting to reconcile ACS node: {}", nodeDbId);
|
this.logger.trace("Attempting to reconcile ACS node: {}", nodeDbId);
|
||||||
|
|||||||
Reference in New Issue
Block a user