397398399400401402403404405406407
NodeState finalState) { ClusterMetrics metrics = ClusterMetrics.getMetrics(); switch (initialState) { case RUNNING: metrics.decrNumActiveNodes(); break; case UNHEALTHY: metrics.decrNumUnhealthyNMs(); break; }
419420421422423424425426427428429
351352353354355356357358359360361
} } private void updateMetricsForDeactivatedNode(NodeState finalState) { ClusterMetrics metrics = ClusterMetrics.getMetrics(); metrics.decrNumActiveNodes(); switch (finalState) { case DECOMMISSIONED: metrics.incrDecommisionedNMs(); break;
342343344345346347348349350351352
348349350351352353354355356357358
} } private void updateMetricsForDeactivatedNode(RMNodeState finalState) { ClusterMetrics metrics = ClusterMetrics.getMetrics(); metrics.decrNumActiveNodes(); switch (finalState) { case DECOMMISSIONED: metrics.incrDecommisionedNMs(); break;
363364365366367368369370371372373
392393394395396397398399400401402
329330331332333334335336337338339
415416417418419420421422423424425