(accumulo) branch elasticity updated: Uncomment code in Monitor that retrieved TServer active compactions (#4407)

[dlmarion]

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

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


The following commit(s) were added to refs/heads/elasticity by this push:
     new 98b994ce0a Uncomment code in Monitor that retrieved TServer active 
compactions (#4407)
98b994ce0a is described below

commit 98b994ce0ad7d67a0e9d028b227909f7b7882ac7
Author: Dave Marion <dlmar...@apache.org>
AuthorDate: Fri Mar 22 08:41:14 2024 -0400

    Uncomment code in Monitor that retrieved TServer active compactions (#4407)
    
    Code was commented out in the Monitor that called
    TabletClientHandler.getActiveCompactions. This method was removed
    when major compactions were removed from the tserver, then restored
    in #3827 because we still need to report minor compaction stats to
    the monitor.
---
 .../monitor/src/main/java/org/apache/accumulo/monitor/Monitor.java  | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git 
a/server/monitor/src/main/java/org/apache/accumulo/monitor/Monitor.java 
b/server/monitor/src/main/java/org/apache/accumulo/monitor/Monitor.java
index 9f8eb68473..1743235fd5 100644
--- a/server/monitor/src/main/java/org/apache/accumulo/monitor/Monitor.java
+++ b/server/monitor/src/main/java/org/apache/accumulo/monitor/Monitor.java
@@ -762,10 +762,8 @@ public class Monitor extends AbstractServer implements 
HighlyAvailableService {
       Client tserver = null;
       try {
         tserver = ThriftUtil.getClient(ThriftClientTypes.TABLET_SERVER, 
parsedServer, context);
-        // ELASTICITY_TODO tservers no longer have any compaction information, 
following code was
-        // commented out as the thrift calls no longer exists
-        // var compacts = tserver.getActiveCompactions(null, 
context.rpcCreds());
-        // allCompactions.put(parsedServer, new CompactionStats(compacts));
+        var compacts = tserver.getActiveCompactions(null, context.rpcCreds());
+        allCompactions.put(parsedServer, new CompactionStats(compacts));
         compactsFetchedNanos = System.nanoTime();
       } catch (Exception ex) {
         log.debug("Failed to get active compactions from {}", server, ex);