lib/fluent/plugin/webhdfs_compressor_bzip2.rb in fluent-plugin-webhdfs-1.1.1 vs lib/fluent/plugin/webhdfs_compressor_bzip2.rb in fluent-plugin-webhdfs-1.2.0

@@ -2,10 +2,14 @@
   class WebHDFSOutput < Output
     class Bzip2Compressor < Compressor
       WebHDFSOutput.register_compressor('bzip2', self)
 
       def initialize(options = {})
-        require "bzip2/ffi"
+        begin
+          require "bzip2/ffi"
+        rescue LoadError
+          raise Fluent::ConfigError, "Install bzip2-ffi before use bzip2 compressor"
+        end
       end
 
       def ext
         ".bz2"
       end