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)