Skip to content

Commit ce24343

Browse files
committed
revert cluster ratio check
1 parent d14e62e commit ce24343

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

cmd/util/cmd/common/clusters.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ func ConstructClusterAssignment(log zerolog.Logger, partnerNodes, internalNodes
8282
}
8383
clusterIndex := i % numCollectionClusters
8484
identifierLists[clusterIndex] = append(identifierLists[clusterIndex], node.NodeID)
85-
constraint[clusterIndex] += 2
85+
constraint[clusterIndex] += 1
8686
}
8787

8888
// next, round-robin partner nodes into each cluster
@@ -92,7 +92,7 @@ func ConstructClusterAssignment(log zerolog.Logger, partnerNodes, internalNodes
9292
}
9393
clusterIndex := i % numCollectionClusters
9494
identifierLists[clusterIndex] = append(identifierLists[clusterIndex], node.NodeID)
95-
constraint[clusterIndex] -= 1
95+
constraint[clusterIndex] -= 2
9696
}
9797

9898
// check the 2/3 constraint: for every cluster `i`, constraint[i] must be strictly positive

0 commit comments

Comments
 (0)