lib/logstash/inputs/jdbc.rb in logstash-input-jdbc-2.0.3 vs lib/logstash/inputs/jdbc.rb in logstash-input-jdbc-2.0.4

@@ -157,10 +157,10 @@
     @statement = File.read(@statement_filepath) if @statement_filepath
   end # def register
 
   def run(queue)
     if @schedule
-      @scheduler = Rufus::Scheduler.new
+      @scheduler = Rufus::Scheduler.new(:max_work_threads => 1)
       @scheduler.cron @schedule do
         execute_query(queue)
       end
 
       @scheduler.join