From 62d58324dd2068f2408fc8f2915e0f3354a9c674 Mon Sep 17 00:00:00 2001 From: Nikolay Date: Mon, 3 May 2021 11:34:00 +0300 Subject: [PATCH] adds stalePartsRemover (#1261) for new created partitions --- lib/storage/partition.go | 1 + 1 file changed, 1 insertion(+) diff --git a/lib/storage/partition.go b/lib/storage/partition.go index 4bf6f833be..7a6327f64e 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)