diff options
Diffstat (limited to 'clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/FleetController.java')
-rw-r--r-- | clustercontroller-core/src/main/java/com/yahoo/vespa/clustercontroller/core/FleetController.java | 4 |
1 files changed, 2 insertions, 2 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 6876ac8cf56..966f6db8deb 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 @@ -1003,7 +1003,7 @@ public class FleetController implements NodeListener, SlobrokListener, SystemSta private boolean atFirstClusterStateSendTimeEdge() { // We only care about triggering a state recomputation for the master, which is the only // one allowed to actually broadcast any states. - if (!isMaster || systemStateBroadcaster.hasBroadcastedClusterStateBundle()) { + if (!isMaster || systemStateBroadcaster.hasBroadcastClusterStateBundle()) { return false; } return hasPassedFirstStateBroadcastTimePoint(timer.getCurrentTimeInMillis()); @@ -1021,7 +1021,7 @@ public class FleetController implements NodeListener, SlobrokListener, SystemSta if ( ! isMaster) { // If we just became master, restore state from ZooKeeper stateChangeHandler.setStateChangedFlag(); - systemStateBroadcaster.resetBroadcastedClusterStateBundle(); + systemStateBroadcaster.resetBroadcastClusterStateBundle(); stateVersionTracker.setVersionRetrievedFromZooKeeper(database.getLatestSystemStateVersion()); ClusterStateBundle previousBundle = database.getLatestClusterStateBundle(); |