diff --git a/lib/fluent/plugin/out_pgjson.rb b/lib/fluent/plugin/out_pgjson.rb
index 3d147bf..cdd9c21 100755
--- a/lib/fluent/plugin/out_pgjson.rb
+++ b/lib/fluent/plugin/out_pgjson.rb
@@ -95,9 +95,12 @@ def write(chunk)
         @conn = nil
         raise
       rescue => err
-        errmsg = "%s while copy data: %s" % [ err.class.name, err.message ]
-        @conn.put_copy_end( errmsg )
-        @conn.get_result
+        conn_status = @conn.status
+        if conn_status==PG::CONNECTION_OK
+            errmsg = "%s while copy data: %s" % [ err.class.name, err.message ]
+            @conn.put_copy_end( errmsg )
+            @conn.get_result
+        end
         @conn.close()
         @conn = nil
         raise