Adding the userId on the compact dir path

Author: alanprot

pkg/compactor/compactor.go

@@ -7,7 +7,6 @@ import (
 	"hash/fnv"
 	"math/rand"
 	"os"
-	"path"
 	"path/filepath"
 	"strings"
 	"time"
@@ -832,7 +831,7 @@ func (c *Compactor) compactUser(ctx context.Context, userID string) error {
 		c.blocksGrouperFactory(currentCtx, c.compactorCfg, bucket, ulogger, reg, c.blocksMarkedForDeletion, c.blocksMarkedForNoCompaction, c.garbageCollectedBlocks, c.remainingPlannedCompactions, c.blockVisitMarkerReadFailed, c.blockVisitMarkerWriteFailed, c.ring, c.ringLifecycler, c.limits, userID, noCompactMarkerFilter),
 		c.blocksPlannerFactory(currentCtx, bucket, ulogger, c.compactorCfg, noCompactMarkerFilter, c.ringLifecycler, c.blockVisitMarkerReadFailed, c.blockVisitMarkerWriteFailed),
 		c.blocksCompactor,
-		path.Join(c.compactorCfg.DataDir, "compact"),
+		c.compactDirForUser(userID),
 		bucket,
 		c.compactorCfg.CompactionConcurrency,
 		c.compactorCfg.SkipBlocksWithOutOfOrderChunksEnabled,
@@ -941,6 +940,11 @@ func (c *Compactor) metaSyncDirForUser(userID string) string {
 	return filepath.Join(c.compactorCfg.DataDir, compactorMetaPrefix+userID)
 }
 
+// compactDirForUser returns the directory to be used to download and compact the blocks date for a user
+func (c *Compactor) compactDirForUser(userID string) string {
+	return filepath.Join(c.compactorCfg.DataDir, "compact", userID)
+}
+
 // This function returns tenants with meta sync directories found on local disk. On error, it returns nil map.
 func (c *Compactor) listTenantsWithMetaSyncDirectories() map[string]struct{} {
 	result := map[string]struct{}{}