diff options
| author | Paul Buetow <pbuetow@mimecast.com> | 2020-07-02 14:14:22 +0100 |
|---|---|---|
| committer | Paul Buetow <pbuetow@mimecast.com> | 2020-07-02 14:14:22 +0100 |
| commit | 27824a01dfd5e5cf2d77ab90a23e209c9851d91a (patch) | |
| tree | 0dcb8e7523089fdd2a3747e26b92cfab9f714bb2 /internal/mapr/client | |
| parent | 41fb325372034c7a42bf0157cdc08894d8371247 (diff) | |
better $line data handling
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" { |