Removed block after each compaction group run.

Fixes: #1499 Signed-off-by: Bartek Plotka <[email protected]>
thanos-io · Oct 18, 2019 · 0ec1e20 · 0ec1e20
1 parent 0c6f3a1
commit 0ec1e20
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/pkg/compact/compact.go b/pkg/compact/compact.go
@@ -599,6 +599,12 @@ func (cg *Group) Compact(ctx context.Context, dir string, comp tsdb.Compactor) (
 
 	subDir := filepath.Join(dir, cg.Key())
 
+	defer func() {
+		if err := os.RemoveAll(subDir); err != nil {
+			level.Error(cg.logger).Log("msg", "failed to remove compaction group work directory", "path", subDir, "err", err)
+		}
+	}()
+
 	if err := os.RemoveAll(subDir); err != nil {
 		return false, ulid.ULID{}, errors.Wrap(err, "clean compaction group dir")
 	}