diff options
author | Harald Musum <musum@yahooinc.com> | 2023-03-29 13:47:53 +0200 |
---|---|---|
committer | Harald Musum <musum@yahooinc.com> | 2023-03-29 13:47:53 +0200 |
commit | b8ff57771da71564dc40ba3e3cc0e05d27c062a5 (patch) | |
tree | c96c58fbee8724ed894fde89e8a6e8d4a557fe62 /clustercontroller-core/src/test/java/com | |
parent | d68318224dd9adb5d5aca7cf16cac2dbc19e4349 (diff) |
Make sure to make correct config for flat clusters (1 group)
Diffstat (limited to 'clustercontroller-core/src/test/java/com')
-rw-r--r-- | clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/NodeStateChangeCheckerTest.java | 26 |
1 files changed, 23 insertions, 3 deletions
diff --git a/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/NodeStateChangeCheckerTest.java b/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/NodeStateChangeCheckerTest.java index 61f87d1a88d..f3c83dba316 100644 --- a/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/NodeStateChangeCheckerTest.java +++ b/clustercontroller-core/src/test/java/com/yahoo/vespa/clustercontroller/core/NodeStateChangeCheckerTest.java @@ -714,13 +714,33 @@ public class NodeStateChangeCheckerTest { } private StorDistributionConfig createDistributionConfig(int nodes) { - return createDistributionConfig(nodes, 1); + var configBuilder = new StorDistributionConfig.Builder() + .active_per_leaf_group(true) + .ready_copies(2) + .redundancy(2) + .initial_redundancy(2); + + var groupBuilder = new StorDistributionConfig.Group.Builder() + .index("invalid") + .name("invalid") + .capacity(nodes); + int nodeIndex = 0; + for (int j = 0; j < nodes; ++j, ++nodeIndex) { + groupBuilder.nodes(new StorDistributionConfig.Group.Nodes.Builder() + .index(nodeIndex)); + } + configBuilder.group(groupBuilder); + + return configBuilder.build(); } + // When more than 1 group private StorDistributionConfig createDistributionConfig(int nodes, int groups) { - if (nodes % groups != 0) { + if (groups == 1) return createDistributionConfig(nodes); + + if (nodes % groups != 0) throw new IllegalArgumentException("Cannot have " + groups + " groups with an odd number of nodes: " + nodes); - } + int nodesPerGroup = nodes / groups; var configBuilder = new StorDistributionConfig.Builder() |