storage_local: Call fsync for XFS. ref #2373

Signed-off-by: Masahiro Nakagawa <repeatedly@gmail.com>
fluent · May 10, 2019 · a9a8586 · a9a8586
1 parent ba7c201
commit a9a8586
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/fluent/plugin/storage_local.rb b/lib/fluent/plugin/storage_local.rb
@@ -133,7 +133,7 @@ def save
         tmp_path = @path + '.tmp'
         begin
           json_string = Yajl::Encoder.encode(@store, pretty: @pretty_print)
-          open(tmp_path, 'w:utf-8', @mode){ |io| io.write json_string }
+          open(tmp_path, 'w:utf-8', @mode) { |io| io.write json_string; io.fsync }
           File.rename(tmp_path, @path)
         rescue => e
           log.error "failed to save data for plugin storage to file", path: @path, tmp: tmp_path, error: e