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;
 

Reply via email to