From 27824a01dfd5e5cf2d77ab90a23e209c9851d91a Mon Sep 17 00:00:00 2001 From: Paul Buetow Date: Thu, 2 Jul 2020 14:14:22 +0100 Subject: better $line data handling --- internal/mapr/client/aggregate.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'internal/mapr/client') diff --git a/internal/mapr/client/aggregate.go b/internal/mapr/client/aggregate.go index fd3a899..e7fcdc6 100644 --- a/internal/mapr/client/aggregate.go +++ b/internal/mapr/client/aggregate.go @@ -71,8 +71,8 @@ func (a *Aggregate) makeFields(parts []string) map[string]string { fields := make(map[string]string, len(parts)) for _, part := range parts { - kv := strings.Split(part, "=") - if len(kv) != 2 { + kv := strings.SplitN(part, "=", 2) + if len(kv) < 2 { continue } if kv[0] == "$line" { -- cgit v1.2.3