This is an automated email from the ASF dual-hosted git repository. dlmarion pushed a commit to branch 1451-external-compactions-feature in repository https://gitbox.apache.org/repos/asf/accumulo.git
The following commit(s) were added to refs/heads/1451-external-compactions-feature by this push: new 0d8becb Formatting changes 0d8becb is described below commit 0d8becb8fb5d91f34c90cc0d92052579d1a9afda Author: Dave Marion <dlmar...@apache.org> AuthorDate: Tue Mar 16 20:49:50 2021 +0000 Formatting changes --- .../java/org/apache/accumulo/coordinator/CompactionCoordinator.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/server/compaction-coordinator/src/main/java/org/apache/accumulo/coordinator/CompactionCoordinator.java b/server/compaction-coordinator/src/main/java/org/apache/accumulo/coordinator/CompactionCoordinator.java index 3f38d6c..4fad8ca 100644 --- a/server/compaction-coordinator/src/main/java/org/apache/accumulo/coordinator/CompactionCoordinator.java +++ b/server/compaction-coordinator/src/main/java/org/apache/accumulo/coordinator/CompactionCoordinator.java @@ -20,7 +20,6 @@ package org.apache.accumulo.coordinator; import java.net.UnknownHostException; import java.util.ArrayList; -import java.util.HashMap; import java.util.HashSet; import java.util.LinkedHashSet; import java.util.List; @@ -323,7 +322,7 @@ public class CompactionCoordinator extends AbstractServer m.remove(entry.getKey(), entry.getValue()); continue; } else { - synchronized(qp) { + synchronized (qp) { TServerInstance tserver = tservers.iterator().next(); LOG.debug("Found tserver {} with priority {} for queue {}", tserver.getHostAndPort(), priority, queue);