diff --git a/symmetric-io/src/main/java/org/jumpmind/symmetric/io/stage/StagingManager.java b/symmetric-io/src/main/java/org/jumpmind/symmetric/io/stage/StagingManager.java
index dd118394ce..8aed675e92 100644
--- a/symmetric-io/src/main/java/org/jumpmind/symmetric/io/stage/StagingManager.java
+++ b/symmetric-io/src/main/java/org/jumpmind/symmetric/io/stage/StagingManager.java
@@ -95,7 +95,8 @@ public long clean(long ttlInMs) {
                 if (resource != null) {
                     boolean resourceIsOld = (System.currentTimeMillis() - resource
                             .getLastUpdateTime()) > ttlInMs;
-                    if (resource.getState() == State.DONE && (resourceIsOld || !resource.exists())) {
+                    if ((resource.getState() == State.DONE || (resource.getState() == State.READY && ttlInMs == 0)) 
+                            && (resourceIsOld || !resource.exists())) {
                         if (!resource.isInUse()) {
                             boolean file = resource.isFileResource();
                             long size = resource.getSize();