summaryrefslogtreecommitdiff
path: root/internal
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2021-09-08 08:39:41 +0300
committerPaul Buetow <paul@buetow.org>2021-09-08 08:39:41 +0300
commitc83c9e61a08c7ea1cb528bc26dfab25b46faa866 (patch)
treebb069a539513cde37027bb119ddaf26380c62024 /internal
parentf74a9e4b35feb8c07d8a70b5a581088a0a59889d (diff)
Don't fail parsing whole line when one kv could not be parsed
Diffstat (limited to 'internal')
-rw-r--r--internal/mapr/logformat/default.go5
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]
}