diff --git a/filebeat/input/filestream/parsers_integration_test.go b/filebeat/input/filestream/parsers_integration_test.go index ed24323e200..3b4d27ffedb 100644 --- a/filebeat/input/filestream/parsers_integration_test.go +++ b/filebeat/input/filestream/parsers_integration_test.go @@ -50,7 +50,7 @@ func TestParsersDockerLogs(t *testing.T) { env.waitUntilEventCount(1) env.requireOffsetInRegistry(testlogName, len(testline)) - env.requireEventContents(0, "json.log", "Fetching main repository github.com/elastic/beats...") + env.requireEventContents(0, "json.log", "Fetching main repository github.com/elastic/beats...\n") env.requireEventContents(0, "json.time", "2016-03-02T22:58:51.338462311Z") env.requireEventContents(0, "json.stream", "stdout") @@ -180,8 +180,6 @@ func TestParsersJavaElasticsearchLogs(t *testing.T) { "paths": []string{env.abspath(testlogName)}, "prospector.scanner.check_interval": "1ms", "parsers": []map[string]interface{}{ - map[string]interface{}{ - "strip_newline": map[string]interface{}{}}, map[string]interface{}{ "multiline": map[string]interface{}{ "type": "pattern", @@ -216,8 +214,6 @@ func TestParsersCStyleLog(t *testing.T) { "paths": []string{env.abspath(testlogName)}, "prospector.scanner.check_interval": "1ms", "parsers": []map[string]interface{}{ - map[string]interface{}{ - "strip_newline": map[string]interface{}{}}, map[string]interface{}{ "multiline": map[string]interface{}{ "type": "pattern", @@ -258,8 +254,6 @@ func TestParsersRabbitMQMultilineLog(t *testing.T) { "paths": []string{env.abspath(testlogName)}, "prospector.scanner.check_interval": "1ms", "parsers": []map[string]interface{}{ - map[string]interface{}{ - "strip_newline": map[string]interface{}{}}, map[string]interface{}{ "multiline": map[string]interface{}{ "type": "pattern", @@ -304,8 +298,6 @@ func TestParsersMultilineMaxLines(t *testing.T) { "paths": []string{env.abspath(testlogName)}, "prospector.scanner.check_interval": "1ms", "parsers": []map[string]interface{}{ - map[string]interface{}{ - "strip_newline": map[string]interface{}{}}, map[string]interface{}{ "multiline": map[string]interface{}{ "type": "pattern", @@ -349,8 +341,6 @@ func TestParsersMultilineTimeout(t *testing.T) { "paths": []string{env.abspath(testlogName)}, "prospector.scanner.check_interval": "1ms", "parsers": []map[string]interface{}{ - map[string]interface{}{ - "strip_newline": map[string]interface{}{}}, map[string]interface{}{ "multiline": map[string]interface{}{ "type": "pattern", @@ -415,8 +405,6 @@ func TestParsersMultilineMaxBytes(t *testing.T) { "prospector.scanner.check_interval": "1ms", "message_max_bytes": 50, "parsers": []map[string]interface{}{ - map[string]interface{}{ - "strip_newline": map[string]interface{}{}}, map[string]interface{}{ "multiline": map[string]interface{}{ "type": "pattern", @@ -458,8 +446,6 @@ func TestParsersCloseTimeoutWithMultiline(t *testing.T) { "prospector.scanner.check_interval": "1ms", "close.reader.after_interval": "100ms", "parsers": []map[string]interface{}{ - map[string]interface{}{ - "strip_newline": map[string]interface{}{}}, map[string]interface{}{ "multiline": map[string]interface{}{ "type": "pattern", @@ -522,8 +508,6 @@ func TestParsersConsecutiveNewline(t *testing.T) { "paths": []string{env.abspath(testlogName)}, "prospector.scanner.check_interval": "1ms", "parsers": []map[string]interface{}{ - map[string]interface{}{ - "strip_newline": map[string]interface{}{}}, map[string]interface{}{ "multiline": map[string]interface{}{ "type": "pattern",