bloom compactor tokens = 10 (hardcoded for now)

Signed-off-by: Owen Diehl <[email protected]>
grafana · Feb 20, 2024 · da748ee · da748ee
1 parent e41085b
commit da748ee
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/pkg/loki/modules.go b/pkg/loki/modules.go
@@ -1446,7 +1446,9 @@ func (t *Loki) initBloomCompactorRing() (services.Service, error) {
 	// is LegacyMode needed?
 	// legacyReadMode := t.Cfg.LegacyReadTarget && t.isModuleActive(Read)
 
-	rm, err := lokiring.NewRingManager(bloomCompactorRingKey, lokiring.ServerMode, t.Cfg.BloomCompactor.Ring, 1, 1, util_log.Logger, prometheus.DefaultRegisterer)
+	// TODO(owen-d): configurable num tokens, just use lifecycler config?
+	numTokens := 10
+	rm, err := lokiring.NewRingManager(bloomCompactorRingKey, lokiring.ServerMode, t.Cfg.BloomCompactor.Ring, 1, numTokens, util_log.Logger, prometheus.DefaultRegisterer)
 
 	if err != nil {
 		return nil, gerrors.Wrap(err, "error initializing bloom-compactor ring manager")