lib/logstash/inputs/jdbc.rb in logstash-integration-jdbc-5.0.0 vs lib/logstash/inputs/jdbc.rb in logstash-integration-jdbc-5.0.1
- old
+ new
@@ -268,9 +268,10 @@
def set_value_tracker(instance)
@value_tracker = instance
end
def run(queue)
+ load_driver
if @schedule
@scheduler = Rufus::Scheduler.new(:max_work_threads => 1)
@scheduler.cron @schedule do
execute_query(queue)
end