diff options
Diffstat (limited to 'internal/mapr/client')
| -rw-r--r-- | internal/mapr/client/aggregate.go | 4 |
1 files changed, 2 insertions, 2 deletions
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" { |