From a38b8e5758a230b41197375310ac1633a6652d0c Mon Sep 17 00:00:00 2001 From: poyzannur Date: Wed, 1 Nov 2023 18:41:22 +0000 Subject: [PATCH] quick fix after introduction of prefix for all keys #10096 --- pkg/bloomcompactor/bloomcompactor.go | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/pkg/bloomcompactor/bloomcompactor.go b/pkg/bloomcompactor/bloomcompactor.go index 432dd385dfe7..7d86ff25edd3 100644 --- a/pkg/bloomcompactor/bloomcompactor.go +++ b/pkg/bloomcompactor/bloomcompactor.go @@ -87,8 +87,16 @@ func New(cfg Config, bloomCompactorRing: readRing, } + var periodConfig config.PeriodConfig + for _, periodCfg := range schemaConfig.Configs { + if periodCfg.IndexType == config.TSDBType { + periodConfig = periodCfg + break + } + } + //Configure ObjectClient and IndexShipper for series and chunk management - objectClient, err := storage.NewObjectClient(storageCfg.TSDBShipperConfig.SharedStoreType, storageCfg, clientMetrics) + objectClient, err := storage.NewObjectClient(periodConfig.ObjectType, storageCfg, clientMetrics) if err != nil { return nil, err } @@ -101,6 +109,7 @@ func New(cfg Config, return tsdb.OpenShippableTSDB(p, tsdb.IndexOpts{}) } indexShipper, err := indexshipper.NewIndexShipper( + periodConfig.IndexTables.PathPrefix, storageCfg.TSDBShipperConfig.Config, objectClient, limits,