chunk: fix binmode for prevent gc

fluent · Sep 29, 2020 · 16fd62d · 16fd62d
1 parent adca029
commit 16fd62d
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/lib/fluent/plugin/buffer/chunk.rb b/lib/fluent/plugin/buffer/chunk.rb
@@ -206,8 +206,9 @@ def open(**kwargs, &block)
                 output_io = if chunk_io.is_a?(StringIO)
                               StringIO.new
                             else
-                              Tempfile.new('decompressed-data').binmode
+                              Tempfile.new('decompressed-data')
                             end
+                output_io.binmode if output_io.is_a?(Tempfile)
                 decompress(input_io: chunk_io, output_io: output_io)
                 output_io.seek(0, IO::SEEK_SET)
                 yield output_io