This is an automated email from the ASF dual-hosted git repository.
dlmarion 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 77ec755405 Minor monitor fixes (#6189)
77ec755405 is described below
commit 77ec7554057da0b576867703d699f0bc916638c2
Author: Dave Marion <[email protected]>
AuthorDate: Fri Mar 6 05:53:13 2026 -0500
Minor monitor fixes (#6189)
---
.../src/main/java/org/apache/accumulo/monitor/next/Endpoints.java | 4 +++-
.../main/java/org/apache/accumulo/monitor/next/SystemInformation.java | 3 ++-
.../accumulo/monitor/next/serializers/MetricResponseSerializer.java | 4 ++--
3 files changed, 7 insertions(+), 4 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 4785dabcf0..9ecab2a74c 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
@@ -105,7 +105,9 @@ public class Endpoints {
* dependency convergence issues as we were using newer version of some of
the same
* dependencies.
*/
- final String basePath = request.getRequestURL().toString();
+ final String requestPath = request.getRequestURL().toString();
+ int idx = requestPath.indexOf("/endpoints");
+ final String basePath = requestPath.substring(0, idx);
final Map<String,String> documentation = new TreeMap<>();
for (Method m : Endpoints.class.getMethods()) {
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 7e2037530d..82f061f06d 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
@@ -275,6 +275,7 @@ public class SystemInformation {
}
public void addNotResponded(ServerId server) {
+ configured.incrementAndGet();
notResponded.add(server.getHost() + ":" + server.getPort());
}
@@ -495,7 +496,7 @@ public class SystemInformation {
}
public void finish() {
- // Iterate over the metrics
+ // Compute the deployment overview
allMetrics.asMap().keySet().forEach(serverId -> {
deployment.computeIfAbsent(serverId.getResourceGroup(), g -> new
ConcurrentHashMap<>())
.computeIfAbsent(serverId.getType().name(), t -> new
ProcessSummary()).addResponded();
diff --git
a/server/monitor/src/main/java/org/apache/accumulo/monitor/next/serializers/MetricResponseSerializer.java
b/server/monitor/src/main/java/org/apache/accumulo/monitor/next/serializers/MetricResponseSerializer.java
index 8fe331ee5a..a058e054f7 100644
---
a/server/monitor/src/main/java/org/apache/accumulo/monitor/next/serializers/MetricResponseSerializer.java
+++
b/server/monitor/src/main/java/org/apache/accumulo/monitor/next/serializers/MetricResponseSerializer.java
@@ -66,9 +66,9 @@ public class MetricResponseSerializer extends
JsonSerializer<MetricResponse> {
}
gen.writeEndObject();
}
- gen.writeEndArray();
- gen.writeEndObject();
}
+ gen.writeEndArray();
+ gen.writeEndObject();
}
}