diff --git a/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/SimpleStagingDataWriter.java b/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/SimpleStagingDataWriter.java
index d24d4510b5..0e75878869 100644
--- a/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/SimpleStagingDataWriter.java
+++ b/symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/SimpleStagingDataWriter.java
@@ -153,6 +153,9 @@ public void process() throws IOException {
                     String location = batch.getStagedLocation();
                     resource = stagingManager.find(category, location, batch.getBatchId());
                     if (resource == null || resource.getState() == State.CREATE) {
+                        if (resource != null) {
+                            resource.delete();
+                        }
                         resource = null;
                         writer = null;
                     }
@@ -214,7 +217,6 @@ public void process() throws IOException {
 
         } catch (Exception ex) {
             if (resource != null) {
-                resource.close();
                 resource.delete();
             }