Merge pull request #37029 from thaJeztah/fix-fluentd-partial

Fix fluentd partial detection Upstream-commit: f4ebcb42ac527b24ab54525d5824478fcd2960c0 Component: engine
2018-05-10 12:51:02 -04:00
parent bc1299683c d10b7a563e
commit a5b8cafc29
1 changed files with 1 additions and 1 deletions
@@ -163,7 +163,7 @@ func (f *fluentd) Log(msg *logger.Message) error {
 	for k, v := range f.extra {
 		data[k] = v
 	}
-	if msg.Partial {
+	if msg.PLogMetaData != nil {
 		data["partial_message"] = "true"
 	}