mirror of
https://github.com/VictoriaMetrics/VictoriaMetrics.git
synced 2025-01-20 15:16:42 +00:00
wip
This commit is contained in:
parent
16a91539bd
commit
75bbe51a05
1 changed files with 6 additions and 0 deletions
|
@ -368,6 +368,12 @@ func (spp *statsPipeProcessor) flush() {
|
||||||
|
|
||||||
// Write per-group states to ppBase
|
// Write per-group states to ppBase
|
||||||
byFields := spp.sp.byFields
|
byFields := spp.sp.byFields
|
||||||
|
if len(byFields) == 0 && len(m) == 0 {
|
||||||
|
// Special case - zero matching rows.
|
||||||
|
_ = shards[0].getStatsPipeGroup(nil)
|
||||||
|
m = shards[0].m
|
||||||
|
}
|
||||||
|
|
||||||
var values []string
|
var values []string
|
||||||
var columns []BlockColumn
|
var columns []BlockColumn
|
||||||
for key, spg := range m {
|
for key, spg := range m {
|
||||||
|
|
Loading…
Reference in a new issue