(accumulo) branch main updated: Removes unused monitor rest endpoint '/ec' (#6317)

[kturner]

This is an automated email from the ASF dual-hosted git repository.

kturner pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/accumulo.git


The following commit(s) were added to refs/heads/main by this push:
     new da4ff8c98d Removes unused monitor rest endpoint '/ec' (#6317)
da4ff8c98d is described below

commit da4ff8c98d0c11f3b94784d4a113824297beea72
Author: Keith Turner <ktur...@apache.org>
AuthorDate: Thu Apr 16 07:02:59 2026 -0700

    Removes unused monitor rest endpoint '/ec' (#6317)
---
 .../main/java/org/apache/accumulo/monitor/next/Endpoints.java | 11 -----------
 .../org/apache/accumulo/monitor/next/InformationFetcher.java  |  8 +-------
 .../org/apache/accumulo/monitor/next/SystemInformation.java   | 10 +---------
 3 files changed, 2 insertions(+), 27 deletions(-)

diff --git 
a/server/monitor/src/main/java/org/apache/accumulo/monitor/next/Endpoints.java 
b/server/monitor/src/main/java/org/apache/accumulo/monitor/next/Endpoints.java
index 061aad19fd..a0b4971413 100644
--- 
a/server/monitor/src/main/java/org/apache/accumulo/monitor/next/Endpoints.java
+++ 
b/server/monitor/src/main/java/org/apache/accumulo/monitor/next/Endpoints.java
@@ -54,7 +54,6 @@ import 
org.apache.accumulo.monitor.next.SystemInformation.TableSummary;
 import 
org.apache.accumulo.monitor.next.SystemInformation.TimeOrderedRunningCompactionSet;
 import org.apache.accumulo.monitor.next.deployment.DeploymentOverview;
 import org.apache.accumulo.monitor.next.ec.CompactorsSummary;
-import org.apache.accumulo.monitor.next.ec.CoordinatorSummary;
 import org.apache.accumulo.monitor.next.views.ServersView;
 
 import io.micrometer.core.instrument.Meter.Id;
@@ -339,16 +338,6 @@ public class Endpoints {
     return longRunning.stream().collect(Collectors.toList());
   }
 
-  @GET
-  @Path("ec")
-  @Produces(MediaType.APPLICATION_JSON)
-  @Description("Returns External Compaction coordinator summary")
-  public CoordinatorSummary getExternalCompactionCoordinator() {
-    var summary = monitor.getInformationFetcher().getSummaryForEndpoint();
-    return CoordinatorSummary.fromHost(summary.getCoordinatorHost(), 
summary.getCompactorServers(),
-        summary.getTimestamp());
-  }
-
   @GET
   @Path("ec/compactors")
   @Produces(MediaType.APPLICATION_JSON)
diff --git 
a/server/monitor/src/main/java/org/apache/accumulo/monitor/next/InformationFetcher.java
 
b/server/monitor/src/main/java/org/apache/accumulo/monitor/next/InformationFetcher.java
index 1991c0f3e4..026828c579 100644
--- 
a/server/monitor/src/main/java/org/apache/accumulo/monitor/next/InformationFetcher.java
+++ 
b/server/monitor/src/main/java/org/apache/accumulo/monitor/next/InformationFetcher.java
@@ -279,14 +279,8 @@ public class InformationFetcher implements 
RemovalListener<ServerId,MetricRespon
 
       final List<Future<?>> futures = new ArrayList<>();
       final SystemInformation summary = new SystemInformation(allMetrics, 
this.ctx);
-      Set<ServerId> managers = 
this.ctx.instanceOperations().getServers(ServerId.Type.MANAGER);
-      HostAndPort coordinatorHost = null;
-      if (!managers.isEmpty()) {
-        ServerId manager = managers.iterator().next();
-        coordinatorHost = HostAndPort.fromParts(manager.getHost(), 
manager.getPort());
-      }
       Set<ServerId> compactors = 
this.ctx.instanceOperations().getServers(Type.COMPACTOR);
-      summary.processExternalCompactionInventory(compactors, coordinatorHost);
+      summary.processExternalCompactionInventory(compactors);
 
       for (ServerId.Type type : ServerId.Type.values()) {
         if (type == Type.MONITOR) {
diff --git 
a/server/monitor/src/main/java/org/apache/accumulo/monitor/next/SystemInformation.java
 
b/server/monitor/src/main/java/org/apache/accumulo/monitor/next/SystemInformation.java
index 16b9911ecd..3c5c4f4475 100644
--- 
a/server/monitor/src/main/java/org/apache/accumulo/monitor/next/SystemInformation.java
+++ 
b/server/monitor/src/main/java/org/apache/accumulo/monitor/next/SystemInformation.java
@@ -71,7 +71,6 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import com.github.benmanes.caffeine.cache.Cache;
-import com.google.common.net.HostAndPort;
 
 import io.micrometer.core.instrument.Clock;
 import io.micrometer.core.instrument.Meter.Id;
@@ -394,7 +393,6 @@ public class SystemInformation {
   // Compaction Information
   private final Map<String,List<FMetric>> queueMetrics = new 
ConcurrentHashMap<>();
   private volatile Set<ServerId> registeredCompactors = Set.of();
-  private volatile HostAndPort coordinatorHost;
 
   protected final Map<String,TimeOrderedRunningCompactionSet> 
longRunningCompactionsByRg =
       new ConcurrentHashMap<>();
@@ -443,7 +441,6 @@ public class SystemInformation {
     rgTServerMetrics.clear();
     queueMetrics.clear();
     registeredCompactors = Set.of();
-    coordinatorHost = null;
     longRunningCompactionsByRg.clear();
     tables.clear();
     tablets.clear();
@@ -559,13 +556,12 @@ public class SystemInformation {
         .add(new RunningCompactionInfo(tec));
   }
 
-  public void processExternalCompactionInventory(Set<ServerId> compactors, 
HostAndPort host) {
+  public void processExternalCompactionInventory(Set<ServerId> compactors) {
     if (compactors == null) {
       registeredCompactors = Set.of();
     } else {
       registeredCompactors = Set.copyOf(compactors);
     }
-    coordinatorHost = host;
   }
 
   public void processTabletInformation(TableId tableId, String tableName, 
TabletInformation info) {
@@ -756,10 +752,6 @@ public class SystemInformation {
     return registeredCompactors;
   }
 
-  public HostAndPort getCoordinatorHost() {
-    return coordinatorHost;
-  }
-
   public Map<String,TimeOrderedRunningCompactionSet> 
getTopRunningCompactions() {
     return this.longRunningCompactionsByRg;
   }