diff options
author | Martin Polden <mpolden@mpolden.no> | 2023-09-04 10:32:05 +0200 |
---|---|---|
committer | Martin Polden <mpolden@mpolden.no> | 2023-09-04 10:32:05 +0200 |
commit | 71157edbc0c75b6f69dc6d04bc0759191c94c4f9 (patch) | |
tree | 33bbc114ed37ae159f5dec8c2d2fa41fce022b6f /node-repository | |
parent | aeb7e91192af2fd1e6479560b5dde65e3c038fd3 (diff) |
Remove unused executor
Diffstat (limited to 'node-repository')
-rw-r--r-- | node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/DiskReplacer.java | 11 |
1 files changed, 0 insertions, 11 deletions
diff --git a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/DiskReplacer.java b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/DiskReplacer.java index 0c1d6291baa..392c6a1433f 100644 --- a/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/DiskReplacer.java +++ b/node-repository/src/main/java/com/yahoo/vespa/hosted/provision/maintenance/DiskReplacer.java @@ -1,7 +1,6 @@ // Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. package com.yahoo.vespa.hosted.provision.maintenance; -import com.yahoo.concurrent.DaemonThreadFactory; import com.yahoo.jdisc.Metric; import com.yahoo.vespa.hosted.provision.Node; import com.yahoo.vespa.hosted.provision.NodeList; @@ -14,8 +13,6 @@ import com.yahoo.yolean.Exceptions; import java.time.Duration; import java.util.List; import java.util.Optional; -import java.util.concurrent.ExecutorService; -import java.util.concurrent.Executors; import java.util.logging.Level; import java.util.logging.Logger; @@ -27,10 +24,8 @@ import java.util.logging.Logger; public class DiskReplacer extends NodeRepositoryMaintainer { private static final Logger log = Logger.getLogger(DiskReplacer.class.getName()); - private static final int maxBatchSize = 100; private final HostProvisioner hostProvisioner; - private final ExecutorService executor = Executors.newCachedThreadPool(new DaemonThreadFactory("disk-replacer")); DiskReplacer(NodeRepository nodeRepository, Duration interval, Metric metric, HostProvisioner hostProvisioner) { super(nodeRepository, interval, metric); @@ -59,10 +54,4 @@ public class DiskReplacer extends NodeRepositoryMaintainer { return this.asSuccessFactorDeviation(rebuilding.size(), failures); } - @Override - public void shutdown() { - super.shutdown(); - executor.shutdown(); - } - } |