0005690: Pulling corrupted batch gets null pointer in loop

JumpMind · Feb 15, 2023 · e6967df · e6967df
1 parent e04560a
commit e6967df
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/AcknowledgeService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/AcknowledgeService.java
@@ -271,7 +271,7 @@ public void checkMissingAck(List<BatchAck> acks, String queue) {
                 nodeId = batch.getNodeId();
             }
         }
-        if (hasCorruptBatch) {
+        if (hasCorruptBatch && parameterService.is(ParameterConstants.STREAM_TO_FILE_ENABLED)) {
             OutgoingBatches batches = engine.getOutgoingBatchService().getOutgoingBatches(nodeId, queue, false);
             if (batches.containsBatches()) {
                 Map<Long, OutgoingBatch> batchMap = new HashMap<Long, OutgoingBatch>();