test

Author: Ahmed Ammar

lib/logstash/inputs/dynamodb.rb

@@ -277,19 +277,17 @@ def setup_stream
 
   private
   def scan(logstash_queue)
-    @logger.warn("Starting scan...")
+    @logger.info("Starting scan...")
     @logstash_writer = DynamoDBBootstrap::BlockingQueueConsumer.new(@number_of_write_threads)
 
     @connector = DynamoDBBootstrap::DynamoDBBootstrapWorker.new(@dynamodb_client, @read_ops, @table_name, @number_of_scan_threads)
     start_table_copy_thread
 
     scan_queue = @logstash_writer.getQueue()
     while !$exit
-      if !@scan_queue.empty?
+      if !scan_queue.empty?
         event = scan_queue.take()
-        @logger.warn("got event...")
         if event.getEntry().nil? and event.getSize() == -1
-          @logger.warn("event is nil")
           break
         end # if event.isEmpty()
         queue_event(@parser.parse_scan(event.getEntry(), event.getSize()), logstash_queue, @host)
@@ -301,7 +299,7 @@ def scan(logstash_queue)
 
   private
   def stream(logstash_queue)
-    @logger.warn("Starting stream...")
+    @logger.info("Starting stream...")
     start_kcl_thread
 
     while !$exit