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 8aed675e92..efb1649bc3 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,9 @@ public long clean(long ttlInMs) {
                 if (resource != null) {
                     boolean resourceIsOld = (System.currentTimeMillis() - resource
                             .getLastUpdateTime()) > ttlInMs;
-                    if ((resource.getState() == State.DONE || (resource.getState() == State.READY && ttlInMs == 0)) 
+                    if ((resource.getState() == State.DONE ||
+                            (resource.getState() == State.READY && resource.getPath().contains("/common/")) ||
+                            (resource.getState() == State.READY && ttlInMs == 0)) 
                             && (resourceIsOld || !resource.exists())) {
                         if (!resource.isInUse()) {
                             boolean file = resource.isFileResource();