Skip to content
This repository was archived by the owner on Dec 15, 2021. It is now read-only.

Commit a8cfee0

Browse files
author
Ahmed Ammar
committed
Reduce sleep time
1 parent bf6d654 commit a8cfee0

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

lib/logstash/inputs/dynamodb.rb

+2-2
Original file line numberDiff line numberDiff line change
@@ -292,7 +292,7 @@ def scan(logstash_queue)
292292
end # if event.isEmpty()
293293
queue_event(@parser.parse_scan(event.getEntry(), event.getSize()), logstash_queue, @host)
294294
else
295-
sleep(1)
295+
sleep(0.01)
296296
end
297297
end # while true
298298
end
@@ -307,7 +307,7 @@ def stream(logstash_queue)
307307
event = @queue.pop()
308308
queue_event(@parser.parse_stream(event), logstash_queue, @host)
309309
else
310-
sleep(1)
310+
sleep(0.01)
311311
end
312312
end # while true
313313
end

0 commit comments

Comments
 (0)