Skip to content

Commit

Permalink
change option name more suitable
Browse files Browse the repository at this point in the history
  • Loading branch information
tagomoris committed Mar 11, 2013
1 parent e2cfeb3 commit 0b9bd90
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
4 changes: 2 additions & 2 deletions lib/fluent/plugin/out_webhdfs.rb
Expand Up @@ -13,7 +13,7 @@ class Fluent::WebHDFSOutput < Fluent::TimeSlicedOutput
config_param :port, :integer, :default => 50070
config_param :namenode, :string, :default => nil # host:port

config_param :ignore_init_error, :bool, :default => false
config_param :ignore_start_check_error, :bool, :default => false

include Fluent::Mixin::ConfigPlaceholders

Expand Down Expand Up @@ -81,7 +81,7 @@ def start
$log.info "webhdfs connection confirmed: #{@namenode_host}:#{@namenode_port}"
rescue
$log.error "webdhfs check request failed!"
raise unless @ignore_init_error
raise unless @ignore_start_check_error
end
end

Expand Down
2 changes: 1 addition & 1 deletion test/plugin/test_out_webhdfs.rb
Expand Up @@ -18,7 +18,7 @@ def test_configure
assert_equal '%Y%m%d', d.instance.time_slice_format
assert_equal false, d.instance.httpfs
assert_nil d.instance.username
assert_equal false, d.instance.ignore_init_error
assert_equal false, d.instance.ignore_start_check_error

assert_equal true, d.instance.output_include_time
assert_equal true, d.instance.output_include_tag
Expand Down

0 comments on commit 0b9bd90

Please sign in to comment.