diff --git a/src/lua/bulk_insert.lua b/src/lua/bulk_insert.lua
index 766918a..7fb5028 100755
--- a/src/lua/bulk_insert.lua
+++ b/src/lua/bulk_insert.lua
@@ -40,6 +40,7 @@ end
 
 function thread_done(thread_9d)
    con:bulk_insert_done()
+   con:disconnect()
 end
 
 function cleanup()