From d87d2a414239315ff19f6880808f9be06f10aa79 Mon Sep 17 00:00:00 2001 From: Duc Hong Date: Fri, 1 Dec 2023 01:28:15 +0200 Subject: [PATCH] Support long scroll id for clear scroll - put the scroll id into the body as new es api instead of marking it in the url --- lib/fluent/plugin/in_elasticsearch.rb | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/fluent/plugin/in_elasticsearch.rb b/lib/fluent/plugin/in_elasticsearch.rb index 032fc12..67d5a7f 100644 --- a/lib/fluent/plugin/in_elasticsearch.rb +++ b/lib/fluent/plugin/in_elasticsearch.rb @@ -286,7 +286,7 @@ def run_slice(slice_id=nil) end router.emit_stream(@tag, es) - client.clear_scroll(scroll_id: scroll_id) if scroll_id + client.clear_scroll(:body => { :scroll_id => scroll_id } ) if scroll_id end def process_scroll_request(scroll_id)