0003010: Batches get stranded in ready state in staging on a cluster

because the ack that moves them to done occurs on a different server. Can't delete memory batches on DONE now that READY is gone.
JumpMind · Mar 12, 2017 · 643a083 · 643a083
1 parent 28dbfdc
commit 643a083
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/symmetric-io/src/main/java/org/jumpmind/symmetric/io/stage/StagedResource.java b/symmetric-io/src/main/java/org/jumpmind/symmetric/io/stage/StagedResource.java
@@ -148,10 +148,6 @@ public void setState(State state) {
             }
         } 
 
-        if (memoryBuffer != null && state == State.DONE) {
-            this.memoryBuffer.setLength(0);
-            this.memoryBuffer = null;
-        }
         refreshLastUpdateTime();
         this.state = state;
         this.file = buildFile(state);