lib/fluent/plugin/s3_compressor_lzo.rb in fluent-plugin-s3-0.5.2 vs lib/fluent/plugin/s3_compressor_lzo.rb in fluent-plugin-s3-0.5.3
- old
+ new
@@ -20,10 +20,10 @@
def compress(chunk, tmp)
w = Tempfile.new("chunk-tmp")
chunk.write_to(w)
w.close
- tmp.close
+
# We don't check the return code because we can't recover lzop failure.
system "lzop #{@command_parameter} -o #{tmp.path} #{w.path}"
ensure
w.close rescue nil
w.unlink rescue nil