Skip to content

Commit

Permalink
quick fix after introduction of prefix for all keys #10096
Browse files Browse the repository at this point in the history
  • Loading branch information
poyzannur committed Nov 1, 2023
1 parent 440a1e9 commit a38b8e5
Showing 1 changed file with 10 additions and 1 deletion.
11 changes: 10 additions & 1 deletion pkg/bloomcompactor/bloomcompactor.go
Expand Up @@ -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
}
Expand All @@ -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,
Expand Down

0 comments on commit a38b8e5

Please sign in to comment.