lib/logstash/inputs/elasticsearch.rb in logstash-input-elasticsearch-4.12.0 vs lib/logstash/inputs/elasticsearch.rb in logstash-input-elasticsearch-4.12.1

@@ -345,10 +345,10 @@
 
     event.set(@docinfo_target, docinfo_target)
   end
 
   def clear_scroll(scroll_id)
-    @client.clear_scroll(scroll_id: scroll_id) if scroll_id
+    @client.clear_scroll(:body => { :scroll_id => scroll_id }) if scroll_id
   rescue => e
     # ignore & log any clear_scroll errors
     logger.warn("Ignoring clear_scroll exception", message: e.message, exception: e.class)
   end