We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4a0406b commit 06ea707Copy full SHA for 06ea707
lib/logstash/outputs/elasticsearch/common.rb
@@ -149,7 +149,7 @@ def safe_bulk(es_actions,actions)
149
@logger.debug("Failed actions for last bad bulk request!", :actions => actions)
150
151
# We retry until there are no errors! Errors should all go to the retry queue
152
- sleep 1
+ sleep @retry_max_interval
153
retry unless @stopping.true?
154
rescue => e
155
# For all other errors print out full connection issues
0 commit comments