diff --git a/state/aggregator_v3.go b/state/aggregator_v3.go index 74139e67e..24fa54118 100644 --- a/state/aggregator_v3.go +++ b/state/aggregator_v3.go @@ -1055,6 +1055,7 @@ func (a *AggregatorV3) mergeFiles(ctx context.Context, files SelectedStaticFiles } }() if r.accounts.any() { + log.Info(fmt.Sprintf("[snapshots] merge: %d-%d", r.accounts.historyStartTxNum/a.aggregationStep, r.accounts.historyEndTxNum/a.aggregationStep)) g.Go(func() error { var err error mf.accountsIdx, mf.accountsHist, err = a.accounts.mergeFiles(ctx, files.accountsIdx, files.accountsHist, r.accounts, workers) diff --git a/state/merge.go b/state/merge.go index 9c448514a..19fdda64a 100644 --- a/state/merge.go +++ b/state/merge.go @@ -663,7 +663,7 @@ func (ii *InvertedIndex) mergeFiles(ctx context.Context, files []*filesItem, sta for _, h := range files { defer h.decompressor.EnableMadvNormal().DisableReadAhead() } - log.Info(fmt.Sprintf("[snapshots] merge: %s.%d-%d.ef", ii.filenameBase, startTxNum/ii.aggregationStep, endTxNum/ii.aggregationStep)) + log.Debug(fmt.Sprintf("[snapshots] merge: %s.%d-%d.ef", ii.filenameBase, startTxNum/ii.aggregationStep, endTxNum/ii.aggregationStep)) var outItem *filesItem var comp *compress.Compressor @@ -805,7 +805,7 @@ func (h *History) mergeFiles(ctx context.Context, indexFiles, historyFiles []*fi return nil, nil, err } if r.history { - log.Info(fmt.Sprintf("[snapshots] merge: %s.%d-%d.v", h.filenameBase, r.historyStartTxNum/h.aggregationStep, r.historyEndTxNum/h.aggregationStep)) + log.Debug(fmt.Sprintf("[snapshots] merge: %s.%d-%d.v", h.filenameBase, r.historyStartTxNum/h.aggregationStep, r.historyEndTxNum/h.aggregationStep)) for _, f := range indexFiles { defer f.decompressor.EnableMadvNormal().DisableReadAhead() }