0002657: Nodes not cleaning staged resources of any type

JumpMind · Jul 14, 2016 · 4a16d95 · 4a16d95
1 parent 6d4e72a
commit 4a16d95
Showing 1 changed file with 3 additions and 1 deletion.
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
@@ -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();