lib/fluent/plugin/out_mysql_bulk.rb in fluent-plugin-mysql-bulk-0.0.5 vs lib/fluent/plugin/out_mysql_bulk.rb in fluent-plugin-mysql-bulk-0.0.6

@@ -94,9 +94,10 @@
       sql = "INSERT INTO #{@table} (#{@column_names.join(',')}) VALUES #{values_templates.join(',')}"
       sql += @on_duplicate_key_update_sql if @on_duplicate_key_update
 
       $log.info "bulk insert values size => #{values_templates.size}"
       @handler.xquery(sql, values)
+      @handler.close
     end
 
     private
 
     def format_proc