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()]++; } }