lib/fluent/plugin/s3_compressor_lzo.rb in fluent-plugin-s3-0.6.0 vs lib/fluent/plugin/s3_compressor_lzo.rb in fluent-plugin-s3-0.6.1
- old
+ new
@@ -18,9 +18,10 @@
'application/x-lzop'.freeze
end
def compress(chunk, tmp)
w = Tempfile.new("chunk-tmp")
+ w.binmode
chunk.write_to(w)
w.close
# We don't check the return code because we can't recover lzop failure.
system "lzop #{@command_parameter} -o #{tmp.path} #{w.path}"