From 504f4e69db9e7757d7d0225d5f136bb361dc7c42 Mon Sep 17 00:00:00 2001
From: Cameron Sparr <cameronsparr@gmail.com>
Date: Fri, 2 Dec 2016 11:36:22 +0000
Subject: [PATCH] file output plugin fixup
---
plugins/outputs/file/file.go | 8 ++++++--
1 file changed, 6 insertions(+), 2 deletions(-)
diff --git a/plugins/outputs/file/file.go b/plugins/outputs/file/file.go
index 5830b7a1..e05d0fe8 100644
--- a/plugins/outputs/file/file.go
+++ b/plugins/outputs/file/file.go
@@ -92,9 +92,13 @@ func (f *File) Write(metrics []telegraf.Metric) error {
}
for _, metric := range metrics {
- _, err := f.writer.Write(metric.Serialize())
+ b, err := f.serializer.Serialize(metric)
if err != nil {
- return fmt.Errorf("FAILED to write message: %s, %s", metric.Serialize(), err)
+ return fmt.Errorf("failed to serialize message: %s", err)
+ }
+ _, err = f.writer.Write(b)
+ if err != nil {
+ return fmt.Errorf("failed to write message: %s, %s", metric.Serialize(), err)
}
}
return nil
--
GitLab