diff options
| author | Paul Buetow <paul@buetow.org> | 2021-09-08 08:39:41 +0300 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2021-09-08 08:39:41 +0300 |
| commit | 22e4d64496ceec906b4d2397468e3d90094b7231 (patch) | |
| tree | bb069a539513cde37027bb119ddaf26380c62024 | |
| parent | 9d80c6c108d0f77eb6ab86684e2eb7f3d0f31c79 (diff) | |
Don't fail parsing whole line when one kv could not be parsed
| -rw-r--r-- | internal/mapr/logformat/default.go | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/internal/mapr/logformat/default.go b/internal/mapr/logformat/default.go index 2881047..da976bd 100644 --- a/internal/mapr/logformat/default.go +++ b/internal/mapr/logformat/default.go @@ -1,9 +1,9 @@ package logformat import ( - "errors" "strings" + "github.com/mimecast/dtail/internal/io/logger" "github.com/mimecast/dtail/internal/protocol" ) @@ -31,7 +31,8 @@ func (p *Parser) MakeFieldsDEFAULT(maprLine string) (map[string]string, error) { for _, kv := range splitted[kvStart:] { keyAndValue := strings.SplitN(kv, "=", 2) if len(keyAndValue) != 2 { - return fields, errors.New("Error parsing mapreduce token: " + kv) + logger.Debug("Unable to parse key-value token, ignoring it", kv) + continue } fields[strings.ToLower(keyAndValue[0])] = keyAndValue[1] } |
