From 0fc857d363f984335221b6303647b2822c5c1218 Mon Sep 17 00:00:00 2001 From: Aliaksandr Valialkin Date: Sun, 23 May 2021 14:02:29 +0300 Subject: [PATCH] lib/{mergeset,storage}: reduce the number of IFNO log messages like `merged ... items across ... blocks in ... seconds` Log these messages if the merge takes more than 30 seconds instead of 10 seconds. --- lib/mergeset/table.go | 2 +- lib/storage/partition.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/lib/mergeset/table.go b/lib/mergeset/table.go index ddd0bac40..ba12ada94 100644 --- a/lib/mergeset/table.go +++ b/lib/mergeset/table.go @@ -965,7 +965,7 @@ func (tb *Table) mergeParts(pws []*partWrapper, stopCh <-chan struct{}, isOuterP } d := time.Since(startTime) - if d > 10*time.Second { + if d > 30*time.Second { logger.Infof("merged %d items across %d blocks in %.3f seconds at %d items/sec to %q; sizeBytes: %d", outItemsCount, outBlocksCount, d.Seconds(), int(float64(outItemsCount)/d.Seconds()), dstPartPath, newPSize) } diff --git a/lib/storage/partition.go b/lib/storage/partition.go index 7a6327f64..9b5118737 100644 --- a/lib/storage/partition.go +++ b/lib/storage/partition.go @@ -1255,7 +1255,7 @@ func (pt *partition) mergeParts(pws []*partWrapper, stopCh <-chan struct{}) erro } d := time.Since(startTime) - if d > 10*time.Second { + if d > 30*time.Second { logger.Infof("merged %d rows across %d blocks in %.3f seconds at %d rows/sec to %q; sizeBytes: %d", outRowsCount, outBlocksCount, d.Seconds(), int(float64(outRowsCount)/d.Seconds()), dstPartPath, newPSize) }