From 8997b90c2c566e7dedcf7dfe333c623649fc6a00 Mon Sep 17 00:00:00 2001 From: Alexei Margasov Date: Wed, 27 Mar 2019 15:35:04 +0500 Subject: [PATCH] fluentd log driver. failed parse last partial message in fluentd #38951 Signed-off-by: Alexei Margasov --- daemon/logger/fluentd/fluentd.go | 3 +++ 1 file changed, 3 insertions(+) diff --git a/daemon/logger/fluentd/fluentd.go b/daemon/logger/fluentd/fluentd.go index 907261f41f..19652d6439 100644 --- a/daemon/logger/fluentd/fluentd.go +++ b/daemon/logger/fluentd/fluentd.go @@ -165,6 +165,9 @@ func (f *fluentd) Log(msg *logger.Message) error { } if msg.PLogMetaData != nil { data["partial_message"] = "true" + data["partial_id"] = msg.PLogMetaData.ID + data["partial_ordinal"] = strconv.Itoa(msg.PLogMetaData.Ordinal) + data["partial_last"] = strconv.FormatBool(msg.PLogMetaData.Last) } ts := msg.Timestamp