diff options
author | Ola Aunrønning <olaa@verizonmedia.com> | 2021-01-04 17:31:51 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2021-01-04 17:31:51 +0100 |
commit | 3c220d12e1c6991fc62f6e157a623d78af17a8cd (patch) | |
tree | 8aa833c59ee4697629836297375c1307a025dd8f | |
parent | 5613779dc559920120f93cf9358d62cad0ddde1e (diff) | |
parent | 5e2a1979667be67d7d70d2a79153bf48c37d8a77 (diff) |
Merge pull request #15898 from vespa-engine/olaa/always-update-is-master-metric
Always set 'is-master' metric. Remove 'master-change'
2 files changed, 3 insertions, 10 deletions
diff --git a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/FleetController.java b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/FleetController.java index 9c9e1042c79..d29b2387db3 100644 --- a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/FleetController.java +++ b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/FleetController.java @@ -1002,7 +1002,6 @@ public class FleetController implements NodeStateOrHostInfoChangeHandler, NodeAd boolean didWork = false; if (masterElectionHandler.isMaster()) { if ( ! isMaster) { - metricUpdater.becameMaster(); // If we just became master, restore state from ZooKeeper stateChangeHandler.setStateChangedFlag(); systemStateBroadcaster.resetBroadcastedClusterStateBundle(); @@ -1032,12 +1031,12 @@ public class FleetController implements NodeStateOrHostInfoChangeHandler, NodeAd if (isMaster) { eventLog.add(new ClusterEvent(ClusterEvent.Type.MASTER_ELECTION, "This node is no longer fleetcontroller master.", timer.getCurrentTimeInMillis())); firstAllowedStateBroadcast = Long.MAX_VALUE; - metricUpdater.noLongerMaster(); failAllVersionDependentTasks(); } wantedStateChanged = false; isMaster = false; } + metricUpdater.updateMasterState(isMaster); return didWork; } diff --git a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/MetricUpdater.java b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/MetricUpdater.java index bc66980db75..650f7756bf9 100644 --- a/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/MetricUpdater.java +++ b/clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/MetricUpdater.java @@ -75,14 +75,8 @@ public class MetricUpdater { metricReporter.set("agreed-master-votes", maxCount); } - public void becameMaster() { - metricReporter.set("is-master", 1); - metricReporter.add("master-change", 1); - } - - public void noLongerMaster() { - metricReporter.set("is-master", 0); - metricReporter.add("master-change", 1); + public void updateMasterState(boolean isMaster) { + metricReporter.set("is-master", isMaster ? 1 : 0); } public void addTickTime(long millis, boolean didWork) { |