summaryrefslogtreecommitdiffstats
path: root/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/StateVersionTrackerTest.java
diff options
context:
space:
mode:
Diffstat (limited to 'clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/StateVersionTrackerTest.java')
-rw-r--r--clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/StateVersionTrackerTest.java9
1 files changed, 9 insertions, 0 deletions
diff --git a/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/StateVersionTrackerTest.java b/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/StateVersionTrackerTest.java
index c92f1badae8..02017972e59 100644
--- a/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/StateVersionTrackerTest.java
+++ b/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/StateVersionTrackerTest.java
@@ -277,11 +277,20 @@ public class StateVersionTrackerTest {
when(distributorNode.isDistributor()).thenReturn(true);
assertFalse(tracker.bucketSpaceMergeCompletionStateHasChanged());
+ // Set baseline state
tracker.updateLatestCandidateStateBundle(ClusterStateBundle
.ofBaselineOnly(stateWithoutAnnotations("distributor:1 storage:1")));
tracker.promoteCandidateToVersionedState(1234);
assertFalse(tracker.bucketSpaceMergeCompletionStateHasChanged());
+ // Current node not in previous stats
+ tracker.handleUpdatedHostInfo(distributorNode, createHostInfo(0));
+ assertTrue(tracker.bucketSpaceMergeCompletionStateHasChanged());
+
+ // Sync aggregated stats
+ tracker.updateLatestCandidateStateBundle(ClusterStateBundle
+ .ofBaselineOnly(stateWithoutAnnotations("distributor:1 storage:1")));
+
// Give 'global' bucket space no buckets pending, which is the same as previous stats
tracker.handleUpdatedHostInfo(distributorNode, createHostInfo(0));
assertFalse(tracker.bucketSpaceMergeCompletionStateHasChanged());