From a032377ebcd121ce58731c3e97d1196ccccd47a9 Mon Sep 17 00:00:00 2001 From: Christian Haudum Date: Tue, 23 Jul 2024 10:38:47 +0200 Subject: [PATCH] fix(blooms): Cleanup temp blockdir in bloom compactor Signed-off-by: Christian Haudum --- pkg/bloomcompactor/controller.go | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/pkg/bloomcompactor/controller.go b/pkg/bloomcompactor/controller.go index b852896bfd27..d53ba80b0123 100644 --- a/pkg/bloomcompactor/controller.go +++ b/pkg/bloomcompactor/controller.go @@ -431,6 +431,9 @@ func (s *SimpleBloomController) buildGaps( built, err := bloomshipper.BlockFrom(tenant, table.Addr(), blk) if err != nil { level.Error(logger).Log("msg", "failed to build block", "err", err) + if err = blk.Reader().Cleanup(); err != nil { + level.Error(logger).Log("msg", "failed to cleanup block directory", "err", err) + } return nil, errors.Wrap(err, "failed to build block") } @@ -439,10 +442,17 @@ func (s *SimpleBloomController) buildGaps( built, ); err != nil { level.Error(logger).Log("msg", "failed to write block", "err", err) + if err = blk.Reader().Cleanup(); err != nil { + level.Error(logger).Log("msg", "failed to cleanup block directory", "err", err) + } return nil, errors.Wrap(err, "failed to write block") } s.metrics.blocksCreated.Inc() + if err := blk.Reader().Cleanup(); err != nil { + level.Error(logger).Log("msg", "failed to cleanup block directory", "err", err) + } + totalGapKeyspace := (gap.bounds.Max - gap.bounds.Min) progress := (built.Bounds.Max - gap.bounds.Min) pct := float64(progress) / float64(totalGapKeyspace) * 100