From d46e6371fc74285d69021af357c1c53963140815 Mon Sep 17 00:00:00 2001 From: Jan Eitzinger Date: Wed, 18 Mar 2026 05:22:39 +0100 Subject: [PATCH] Add log about checkpoint archiving Entire-Checkpoint: bf29af79b268 --- pkg/metricstore/archive.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/pkg/metricstore/archive.go b/pkg/metricstore/archive.go index 5c1a8f0f..deebc869 100644 --- a/pkg/metricstore/archive.go +++ b/pkg/metricstore/archive.go @@ -171,6 +171,9 @@ func deleteCheckpoints(checkpointsDir string, from int64) (int, error) { // Each host's rows are written as a separate row group to avoid accumulating // all data in memory at once. func archiveCheckpoints(checkpointsDir, cleanupDir string, from int64) (int, error) { + cclog.Info("[METRICSTORE]> start archiving checkpoints to parquet") + startTime := time.Now() + clusterEntries, err := os.ReadDir(checkpointsDir) if err != nil { return 0, err @@ -300,5 +303,6 @@ func archiveCheckpoints(checkpointsDir, cleanupDir string, from int64) (int, err writer.count, totalFiles, cluster, parquetFile) } + cclog.Infof("[METRICSTORE]> archiving checkpoints completed in %s (%d files)", time.Since(startTime).Round(time.Millisecond), totalFiles) return totalFiles, nil }