adds stalePartsRemover (#1261)

for new created partitions
This commit is contained in:
Nikolay 2021-05-03 11:34:00 +03:00 committed by GitHub
parent 9a930720b3
commit 477369b62f
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23

View file

@ -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)