You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@accumulo.apache.org by dl...@apache.org on 2021/03/16 20:50:06 UTC
[accumulo] branch 1451-external-compactions-feature updated:
Formatting changes
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 <dl...@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);