From 0f63dd4f60e3b76b89d54e4084234708fe5ba9d2 Mon Sep 17 00:00:00 2001
From: Chris Henson <chenson42@gmail.com>
Date: Tue, 1 Aug 2017 08:18:47 -0400
Subject: [PATCH] 0003214: Close & delete resource if retry command comes
 through and the create file has been stranded in staging

---
 .../symmetric/io/data/writer/SimpleStagingDataWriter.java     | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

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();
             }