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

- old
+ new

@@ -257,12 +257,11 @@ update_state_file end end # def run def stop - @scheduler.stop if @scheduler - close_jdbc_connection + @scheduler.stop if @scheduler end private def execute_query(queue)