CL-Softwares
/
telegraf
8
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix(parsers.json_v2): Reset state before parsing (#14344)

This commit is contained in:
agiilit-admin 2023-11-30 23:51:12 +01:00 committed by GitHub
parent 00d145eae8
commit e17ee6dead
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
plugins/parsers/json_v2/parser.go
View File

@ -130,6 +130,10 @@ func (p *Parser) Parse(input []byte) ([]telegraf.Metric, error) {
func (p *Parser) parseCriticalPath(input []byte) ([]telegraf.Metric, error) { func (p *Parser) parseCriticalPath(input []byte) ([]telegraf.Metric, error) {
p.parseMutex.Lock() p.parseMutex.Lock()
defer p.parseMutex.Unlock() defer p.parseMutex.Unlock()
// Clear intermediate results if left by previous call
p.subPathResults = nil
reader := strings.NewReader(string(input)) reader := strings.NewReader(string(input))
body, _ := utfbom.Skip(reader) body, _ := utfbom.Skip(reader)
input, err := io.ReadAll(body) input, err := io.ReadAll(body)