diff options
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.java | 9 |
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()); |