diff --git a/lib/storage/partition.go b/lib/storage/partition.go index 4bf6f833b..7a6327f64 100644 --- a/lib/storage/partition.go +++ b/lib/storage/partition.go @@ -229,6 +229,7 @@ func createPartition(timestamp int64, smallPartitionsPath, bigPartitionsPath str pt.startMergeWorkers() pt.startRawRowsFlusher() pt.startInmemoryPartsFlusher() + pt.startStalePartsRemover() logger.Infof("partition %q has been created", name)