lib/logstash/inputs/jdbc.rb in logstash-input-jdbc-4.3.2 vs lib/logstash/inputs/jdbc.rb in logstash-input-jdbc-4.3.3

@@ -258,10 +258,10 @@
     end
   end # def run
 
   def stop
     close_jdbc_connection
-    @scheduler.stop if @scheduler
+    @scheduler.shutdown(:wait) if @scheduler
   end
 
   private
 
   def execute_query(queue)