0003181: Corrupt batch on remote target node after an "out of disk space

error"
JumpMind · Jul 3, 2017 · 18431bd · 18431bd
1 parent dd240e5
commit 18431bd
Showing 1 changed file with 1 addition and 5 deletions.
diff --git a/...etric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/SimpleStagingDataWriter.java b/...etric-io/src/main/java/org/jumpmind/symmetric/io/data/writer/SimpleStagingDataWriter.java
@@ -121,11 +121,7 @@ public void process() throws IOException {
                     batch = new Batch(batchType, Long.parseLong(getArgLine(line)), getArgLine(channelLine), getBinaryEncoding(binaryLine),
                             getArgLine(nodeLine), targetNodeId, false);
                     String location = batch.getStagedLocation();
-                    resource = stagingManager.find(category, location, batch.getBatchId());
-                    if (resource == null || resource.getState() != State.DONE) {
-                        log.debug("Creating staged resource for batch {}", batch.getNodeBatchId());
-                        resource = stagingManager.create(category, location, batch.getBatchId());
-                    }
+                    resource = stagingManager.create(category, location, batch.getBatchId());
                     writer = resource.getWriter(memoryThresholdInBytes);
                     writeLine(nodeLine);
                     writeLine(binaryLine);