add grok parser check

qiniu · Jun 27, 2017 · d6c0ddd · d6c0ddd
1 parent f7a79b9
commit d6c0ddd
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/parser/grok_parser.go b/parser/grok_parser.go
@@ -323,6 +323,11 @@ func (p *GrokParser) parseLine(line string) (sender.Data, error) {
 			data[k] = strings.Trim(v, `"`)
 		}
 	}
+
+	if len(data) <= 0 {
+		return data, fmt.Errorf("all data was ignored in this line? Check WARN log and fix your grok pattern")
+	}
+
 	for _, l := range p.labels {
 		data[l.name] = l.dataValue
 	}