diff --git a/plugins/parsers/json_v2/parser.go b/plugins/parsers/json_v2/parser.go index 9c3b2c033..b8be884cc 100644 --- a/plugins/parsers/json_v2/parser.go +++ b/plugins/parsers/json_v2/parser.go @@ -346,6 +346,7 @@ func (p *Parser) expandArray(result MetricNode, timestamp time.Time) ([]telegraf n.ParentIndex = n.Index + result.ParentIndex r, err := p.combineObject(n, timestamp) if err != nil { + p.Log.Error(err) return false } @@ -366,6 +367,7 @@ func (p *Parser) expandArray(result MetricNode, timestamp time.Time) ([]telegraf n.ParentIndex = n.Index + result.ParentIndex r, err := p.expandArray(n, timestamp) if err != nil { + p.Log.Error(err) return false } results = append(results, r...) @@ -586,6 +588,7 @@ func (p *Parser) combineObject(result MetricNode, timestamp time.Time) ([]telegr if val.IsObject() { results, err = p.combineObject(arrayNode, timestamp) if err != nil { + p.Log.Error(err) return false } } else { @@ -593,6 +596,7 @@ func (p *Parser) combineObject(result MetricNode, timestamp time.Time) ([]telegr arrayNode.ParentIndex -= result.Index r, err := p.expandArray(arrayNode, timestamp) if err != nil { + p.Log.Error(err) return false } results = cartesianProduct(r, results)