mirror of
https://github.com/VictoriaMetrics/VictoriaMetrics.git
synced 2025-03-21 15:45:01 +00:00
lib/storage: removed duplicate checks for empty parts during merge - another check is in the beginning of mergeParts functions
This commit is contained in:
parent
f2a449983d
commit
020bd8685e
1 changed files with 0 additions and 6 deletions
|
@ -940,9 +940,6 @@ func (pt *partition) mergeBigParts(isFinal bool) error {
|
||||||
pws := getPartsToMerge(pt.bigParts, maxRows, isFinal)
|
pws := getPartsToMerge(pt.bigParts, maxRows, isFinal)
|
||||||
pt.partsLock.Unlock()
|
pt.partsLock.Unlock()
|
||||||
|
|
||||||
if len(pws) == 0 {
|
|
||||||
return errNothingToMerge
|
|
||||||
}
|
|
||||||
return pt.mergeParts(pws, pt.stopCh)
|
return pt.mergeParts(pws, pt.stopCh)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -961,9 +958,6 @@ func (pt *partition) mergeSmallParts(isFinal bool) error {
|
||||||
pws := getPartsToMerge(pt.smallParts, maxRows, isFinal)
|
pws := getPartsToMerge(pt.smallParts, maxRows, isFinal)
|
||||||
pt.partsLock.Unlock()
|
pt.partsLock.Unlock()
|
||||||
|
|
||||||
if len(pws) == 0 {
|
|
||||||
return errNothingToMerge
|
|
||||||
}
|
|
||||||
return pt.mergeParts(pws, pt.stopCh)
|
return pt.mergeParts(pws, pt.stopCh)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue