Skip to content

Commit d94c83a

Browse files
Update in_opensearch.rb
Refactor retry logic
1 parent e79f873 commit d94c83a

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

lib/fluent/plugin/in_opensearch.rb

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -345,7 +345,7 @@ def update_retry_state(error=nil)
345345
@retry.step
346346
if error.message.include?('EOFError (EOFError)')
347347
log.error("Restart plugin because hit error #{error.message}")
348-
exit(1)
348+
start
349349
end
350350
#Raise error if the retry limit has been reached
351351
raise "Hit limit for retries. retry_times: #{@retry.steps}, error: #{error.message}" if @retry.limit?
@@ -370,7 +370,7 @@ def run
370370
run_slice(slice_id)
371371
end
372372
end
373-
rescue Faraday::ConnectionFailed, Faraday::TimeoutError, OpenSearch::Transport::Transport::Error => error
373+
rescue => error
374374
update_retry_state(error)
375375
retry
376376
end

0 commit comments

Comments
 (0)