Increase number of cache partitions

clebs · Jan 31, 2017 · 278c144 · 278c144
1 parent 2fe8ed3
commit 278c144
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/tsdb/engine/tsm1/cache.go b/tsdb/engine/tsm1/cache.go
@@ -18,7 +18,7 @@ import (
 // testing, a value above the number of cores on the machine does not provide
 // any additional benefit. For now we'll set it to the number of cores on the
 // largest box we could imagine running influx.
-const ringShards = 128
+const ringShards = 4096
 
 var (
 	// ErrSnapshotInProgress is returned if a snapshot is attempted while one is already running.

diff --git a/tsdb/engine/tsm1/ring.go b/tsdb/engine/tsm1/ring.go
@@ -13,7 +13,7 @@ import (
 // basically defines the maximum number of partitions you can have in the ring.
 // If a smaller number of partitions are chosen when creating a ring, then
 // they're evenly spread across this many partitions in the ring.
-const partitions = 256
+const partitions = 4096
 
 // ring is a structure that maps series keys to entries.
 //
@@ -92,7 +92,7 @@ func (r *ring) reset() {
 // getPartition retrieves the hash ring partition associated with the provided
 // key.
 func (r *ring) getPartition(key string) *partition {
-	return r.continuum[int(uint8(xxhash.Sum64([]byte(key))))]
+	return r.continuum[int(xxhash.Sum64([]byte(key))%partitions)]
 }
 
 // entry returns the entry for the given key.