This is an automated email from the ASF dual-hosted git repository. domgarguilo pushed a commit to branch elasticity in repository https://gitbox.apache.org/repos/asf/accumulo.git
The following commit(s) were added to refs/heads/elasticity by this push: new 4c3b2d0a58 fix spotbugs error of unused method in ExternalCompactionProgressIT 4c3b2d0a58 is described below commit 4c3b2d0a58b5ffc9da1ad07b2162b519b65af687 Author: Dom Garguilo <domgargu...@apache.org> AuthorDate: Tue Jul 9 17:38:35 2024 -0400 fix spotbugs error of unused method in ExternalCompactionProgressIT --- .../test/compaction/ExternalCompactionProgressIT.java | 15 --------------- 1 file changed, 15 deletions(-) diff --git a/test/src/main/java/org/apache/accumulo/test/compaction/ExternalCompactionProgressIT.java b/test/src/main/java/org/apache/accumulo/test/compaction/ExternalCompactionProgressIT.java index f76b816d73..515c67ec57 100644 --- a/test/src/main/java/org/apache/accumulo/test/compaction/ExternalCompactionProgressIT.java +++ b/test/src/main/java/org/apache/accumulo/test/compaction/ExternalCompactionProgressIT.java @@ -36,7 +36,6 @@ import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.Optional; -import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicLong; @@ -126,26 +125,12 @@ public class ExternalCompactionProgressIT extends AccumuloClusterHarness { cfg.setSystemProperties(sysProps); } - private static long computeBusyCount(String resourceGroup, - ConcurrentHashMap<String,Long> compactorBusy) { - var stats = - compactorBusy.entrySet().stream().filter(e -> e.getKey().startsWith(resourceGroup + ":")) - .mapToLong(Map.Entry::getValue).summaryStatistics(); - if (stats.getCount() == 0) { - // signifies nothing was present, this differentiates between the case where things are - // present w/ a zero value - return -1; - } - return stats.getSum(); - } - @Test public void testProgressViaMetrics() throws Exception { String table = this.getUniqueNames(1)[0]; final AtomicLong totalEntriesRead = new AtomicLong(0); final AtomicLong totalEntriesWritten = new AtomicLong(0); - final ConcurrentHashMap<String,Long> compactorBusy = new ConcurrentHashMap<>(); final long expectedEntriesRead = 18432; final long expectedEntriesWritten = 13312;