diff --git a/lib/embulk/input/elasticsearch/connection.rb b/lib/embulk/input/elasticsearch/connection.rb index 0d05e38..4173e36 100644 --- a/lib/embulk/input/elasticsearch/connection.rb +++ b/lib/embulk/input/elasticsearch/connection.rb @@ -74,7 +74,7 @@ def search_with_retry retry end msg = "Could not search to Elasticsearch after #{retries} retries. #{e.message}" - raise Elasticsearch::ConfigError(e, msg) + raise Elasticsearch::ConfigError.new(e, msg) end end