diff --git a/splitter/splitter.go b/splitter/splitter.go index 7880318..d8c93d6 100644 --- a/splitter/splitter.go +++ b/splitter/splitter.go @@ -221,7 +221,6 @@ func splitAWSRDS(b LogEventBatch) ([]RSysLogMessage, bool) { out = append(out, RSysLogMessage{ Timestamp: event.Timestamp.Time(), ProgramName: databaseName, - PID: 1, Hostname: "aws-rds", Message: event.Message, }) diff --git a/splitter/splitter_test.go b/splitter/splitter_test.go index c903931..6075230 100644 --- a/splitter/splitter_test.go +++ b/splitter/splitter_test.go @@ -242,7 +242,7 @@ func TestSplitRDS(t *testing.T) { } lines := Split(input) expected := [][]byte{ - []byte(`2017-06-26T23:32:23.285001+00:00 aws-rds production-aurora-test-db[1]: Slow query: select * from table.`), + []byte(`2017-06-26T23:32:23.285001+00:00 aws-rds production-aurora-test-db: Slow query: select * from table.`), } assert.Equal(t, expected, lines) for _, line := range expected {