adds stalePartsRemover (#1261)

for new created partitions
This commit is contained in:
Nikolay 2021-05-03 11:34:00 +03:00 committed by Aliaksandr Valialkin
parent 60ffbcbb99
commit 62d58324dd

View file

@ -229,6 +229,7 @@ func createPartition(timestamp int64, smallPartitionsPath, bigPartitionsPath str
pt.startMergeWorkers() pt.startMergeWorkers()
pt.startRawRowsFlusher() pt.startRawRowsFlusher()
pt.startInmemoryPartsFlusher() pt.startInmemoryPartsFlusher()
pt.startStalePartsRemover()
logger.Infof("partition %q has been created", name) logger.Infof("partition %q has been created", name)