[accumulo] branch 1451-external-compactions-feature updated: Populate the running metric count based on RUNNING map size

[dlmarion]

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 54d6c37  Populate the running metric count based on RUNNING map size
54d6c37 is described below

commit 54d6c37ec309d4e0134e335d650103cd6db2d2a7
Author: Dave Marion <dlmar...@apache.org>
AuthorDate: Mon Apr 26 19:56:48 2021 +0000

    Populate the running metric count based on RUNNING map size
---
 .../org/apache/accumulo/coordinator/CompactionCoordinator.java   | 9 +++++----
 .../apache/accumulo/coordinator/ExternalCompactionMetrics.java   | 4 ----
 2 files changed, 5 insertions(+), 8 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 8209057..f8c9d65 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
@@ -30,6 +30,10 @@ import java.util.UUID;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.TimeUnit;
 
+import jakarta.servlet.ServletException;
+import jakarta.servlet.http.HttpServletRequest;
+import jakarta.servlet.http.HttpServletResponse;
+
 import org.apache.accumulo.coordinator.QueueSummaries.PrioTserver;
 import org.apache.accumulo.core.Constants;
 import org.apache.accumulo.core.client.AccumuloSecurityException;
@@ -91,10 +95,6 @@ import org.slf4j.LoggerFactory;
 
 import com.google.gson.Gson;
 
-import jakarta.servlet.ServletException;
-import jakarta.servlet.http.HttpServletRequest;
-import jakarta.servlet.http.HttpServletResponse;
-
 public class CompactionCoordinator extends AbstractServer
     implements 
org.apache.accumulo.core.compaction.thrift.CompactionCoordinator.Iface,
     LiveTServerSet.Listener {
@@ -257,6 +257,7 @@ public class CompactionCoordinator extends AbstractServer
         baseRequest.setHandled(true);
         response.setStatus(200);
         response.setContentType("application/json");
+        metrics.setRunning(RUNNING.size());
         response.getWriter().print(metrics.toJson(GSON));
       }
     });
diff --git 
a/server/compaction-coordinator/src/main/java/org/apache/accumulo/coordinator/ExternalCompactionMetrics.java
 
b/server/compaction-coordinator/src/main/java/org/apache/accumulo/coordinator/ExternalCompactionMetrics.java
index 2343583..2ad35f4 100644
--- 
a/server/compaction-coordinator/src/main/java/org/apache/accumulo/coordinator/ExternalCompactionMetrics.java
+++ 
b/server/compaction-coordinator/src/main/java/org/apache/accumulo/coordinator/ExternalCompactionMetrics.java
@@ -47,10 +47,6 @@ public class ExternalCompactionMetrics {
     this.running = running;
   }
 
-  public void incrementRunning() {
-    this.running++;
-  }
-
   public long getCompleted() {
     return completed;
   }