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 3f3bf62bf4d..29887666a1b 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 @@ -1006,7 +1006,7 @@ public class FleetController implements NodeListener, SlobrokListener, SystemSta private AnnotatedClusterState computeCurrentAnnotatedState() { ClusterStateGenerator.Params params = ClusterStateGenerator.Params.fromOptions(options); - params.currentTimeInMillis(timer.getCurrentTimeInMillis()) + params.currentTimeInMilllis(timer.getCurrentTimeInMillis()) .cluster(cluster) .lowestObservedDistributionBitCount(stateVersionTracker.getLowestObservedDistributionBits()); return ClusterStateGenerator.generatedStateFrom(params); @@ -1200,7 +1200,7 @@ public class FleetController implements NodeListener, SlobrokListener, SystemSta while (true) { int distCount = 0, storCount = 0; for (NodeInfo info : cluster.getNodeInfos()) { - if (info.isInSlobrok()) { + if (!info.isRpcAddressOutdated()) { if (info.isDistributor()) ++distCount; else ++storCount; } |