Merge pull request #48 from oplehto/filter_linelength_fix

filter: Incremented the minimum line length threshold
jumptrading · Mar 13, 2018 · eef3cac · eef3cac
2 parents f4c670d + b980faf
commit eef3cac
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/filter/worker.go b/filter/worker.go
@@ -148,7 +148,7 @@ func extractTimestamp(line []byte, defaultTs int64) int64 {
 	length := len(line)
 
 	// Reject lines that are too short to have a timestamp.
-	if length <= minTsLen {
+	if length <= minTsLen+6 {
 		return defaultTs
 	}