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 <[email protected]>
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;