restore and fix hash

grafana · Oct 7, 2022 · 1b21e43 · 1b21e43
1 parent 98bccbb
commit 1b21e43
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/pkg/schema/partition.go b/pkg/schema/partition.go
@@ -108,9 +108,9 @@ func (m *MetricDefinition) PartitionID(method PartitionByMethod, partitions int3
 			partition = -partition
 		}
 	case PartitionBySeriesWithTags:
-		// h := xxhash.New()
-		// h.WriteString(m.NameWithTags())
-		// partition = jump.Hash(h.Sum64(), int(partitions))
+		h := xxhash.New()
+		h.Write([]byte(m.NameWithTags()))
+		partition = jump.Hash(h.Sum64(), int(partitions))
 	case PartitionBySeriesWithTagsFnv:
 		h := util.NewFnv32aStringWriter()
 		if len(m.nameWithTags) > 0 {