0003214: Close & delete resource if retry command comes through and the

create file has been stranded in staging
JumpMind · Aug 1, 2017 · 0f63dd4 · 0f63dd4
1 parent e6c67fc
commit 0f63dd4
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/...etric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/SimpleStagingDataWriter.java b/...etric-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();
             }