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 36adc8e67e Ensured that TabletMgmtStats are incremented in 
TabletGroupWatcher (#4272)
36adc8e67e is described below

commit 36adc8e67e9468e49d19102044315738659151d2
Author: Dave Marion <dlmar...@apache.org>
AuthorDate: Wed Feb 21 10:09:07 2024 -0500

    Ensured that TabletMgmtStats are incremented in TabletGroupWatcher (#4272)
    
    Fixes #4233
---
 .../src/main/java/org/apache/accumulo/manager/TabletGroupWatcher.java | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/server/manager/src/main/java/org/apache/accumulo/manager/TabletGroupWatcher.java
 
b/server/manager/src/main/java/org/apache/accumulo/manager/TabletGroupWatcher.java
index 37c12dd96c..9f1deac81e 100644
--- 
a/server/manager/src/main/java/org/apache/accumulo/manager/TabletGroupWatcher.java
+++ 
b/server/manager/src/main/java/org/apache/accumulo/manager/TabletGroupWatcher.java
@@ -361,7 +361,7 @@ abstract class TabletGroupWatcher extends 
AccumuloDaemonThread {
       throws BadLocationStateException, TException, DistributedStoreException, 
WalMarkerException,
       IOException {
 
-    TableMgmtStats tableMgmtStats = new TableMgmtStats();
+    final TableMgmtStats tableMgmtStats = new TableMgmtStats();
     final boolean shuttingDownAllTabletServers =
         
tableMgmtParams.getServersToShutdown().equals(currentTServers.keySet());
     if (shuttingDownAllTabletServers && !isFullScan) {
@@ -446,6 +446,7 @@ abstract class TabletGroupWatcher extends 
AccumuloDaemonThread {
           state = newState;
         }
       }
+      tableMgmtStats.counts[state.ordinal()]++;
 
       // This is final because nothing in this method should change the goal. 
All computation of the
       // goal should be done in TabletGoalState.compute() so that all parts of 
the Accumulo code
@@ -619,7 +620,6 @@ abstract class TabletGroupWatcher extends 
AccumuloDaemonThread {
               break;
           }
         }
-        tableMgmtStats.counts[state.ordinal()]++;
       }
     }
 

Reply via email to