feat: improve processors filtering stats (#4882)
This commit is contained in:
parent
65ef38e5c2
commit
e8300b71c5
@ -208,11 +208,11 @@ func (r *Runner) printPerProcessorStat(stat map[string]processorStat) {
|
||||
parts := make([]string, 0, len(stat))
|
||||
for name, ps := range stat {
|
||||
if ps.inCount != 0 {
|
||||
parts = append(parts, fmt.Sprintf("%s: %d/%d", name, ps.outCount, ps.inCount))
|
||||
parts = append(parts, fmt.Sprintf("%s: %d/%d", name, ps.inCount, ps.outCount))
|
||||
}
|
||||
}
|
||||
if len(parts) != 0 {
|
||||
r.Log.Infof("Processors filtering stat (out/in): %s", strings.Join(parts, ", "))
|
||||
r.Log.Infof("Processors filtering stat (in/out): %s", strings.Join(parts, ", "))
|
||||
}
|
||||
}
|
||||
|
||||
|
Loading…
x
Reference in New Issue
Block a user