Fix static topology ShardSet HashFn (#4242)

m3db · Jun 21, 2023 · 7d7c940 · 7d7c940
1 parent 8241941
commit 7d7c940
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/dbnode/environment/config.go b/src/dbnode/environment/config.go
@@ -456,7 +456,7 @@ func generatePlacement(hosts []topology.HostShardConfig, numShards int, rf int)
 	sort.Slice(sortedHosts, func(i, j int) bool { return sortedHosts[i].HostID < sortedHosts[j].HostID })
 	for i, host := range sortedHosts {
 		host := topology.NewHost(host.HostID, host.ListenAddress)
-		shardSet, err := sharding.NewShardSet(hostShards[i], sharding.DefaultHashFn(len(hostShards[i])))
+		shardSet, err := sharding.NewShardSet(hostShards[i], sharding.DefaultHashFn(numShards))
 		if err != nil {
 			return nil, fmt.Errorf("error constructing new ShardSet: %w", err)
 		}