aboutsummaryrefslogtreecommitdiffstats
path: root/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeRetirerTester.java
diff options
context:
space:
mode:
Diffstat (limited to 'node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeRetirerTester.java')
-rw-r--r--node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeRetirerTester.java7
1 files changed, 4 insertions, 3 deletions
diff --git a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeRetirerTester.java b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeRetirerTester.java
index 64613f1bf56..5e33e863df7 100644
--- a/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeRetirerTester.java
+++ b/node-repository/src/test/java/com/yahoo/vespa/hosted/provision/maintenance/NodeRetirerTester.java
@@ -41,6 +41,7 @@ import java.util.List;
import java.util.Map;
import java.util.Optional;
import java.util.stream.Collectors;
+import java.util.stream.LongStream;
import static org.junit.Assert.assertEquals;
import static org.mockito.Matchers.any;
@@ -163,9 +164,9 @@ public class NodeRetirerTester {
}
void assertParkedCountsByApplication(long... nums) {
- Map<ApplicationId, Long> expected = expectedCountsByApplication(nums);
- Map<ApplicationId, Long> actual = nodeRepository.getNodes(Node.State.parked).stream()
- .collect(Collectors.groupingBy(node -> node.allocation().get().owner(), Collectors.counting()));
+ // Nodes lose allocation when parked, so just do a sum.
+ long expected = LongStream.of(nums).filter(value -> value > 0L).sum();
+ long actual = (long) nodeRepository.getNodes(Node.State.parked).size();
assertEquals(expected, actual);
}