diff --git a/CHANGELOG.md b/CHANGELOG.md
index ba71d41..236503d 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -1,3 +1,6 @@
+## 4.3.3
+  - [#255](https://github.com/logstash-plugins/logstash-input-jdbc/issues/255) Fix thread and memory leak.
+  
 ## 4.3.2
   - [#251](https://github.com/logstash-plugins/logstash-input-jdbc/issues/251) Fix connection and memory leak.
   
diff --git a/lib/logstash/inputs/jdbc.rb b/lib/logstash/inputs/jdbc.rb
index ff1f9c0..0e122ad 100755
--- a/lib/logstash/inputs/jdbc.rb
+++ b/lib/logstash/inputs/jdbc.rb
@@ -260,7 +260,7 @@ def run(queue)
 
   def stop
     close_jdbc_connection
-    @scheduler.stop if @scheduler
+    @scheduler.shutdown(:wait) if @scheduler
   end
 
   private
diff --git a/logstash-input-jdbc.gemspec b/logstash-input-jdbc.gemspec
index 5af31d5..1c67dde 100755
--- a/logstash-input-jdbc.gemspec
+++ b/logstash-input-jdbc.gemspec
@@ -1,6 +1,6 @@
 Gem::Specification.new do |s|
   s.name = 'logstash-input-jdbc'
-  s.version         = '4.3.2'
+  s.version         = '4.3.3'
   s.licenses = ['Apache License (2.0)']
   s.summary = "Creates events from JDBC data"
   s.description     = "This gem is a Logstash plugin required to be installed on top of the Logstash core pipeline using $LS_HOME/bin/logstash-plugin install gemname. This gem is not a stand-alone program"