From 5c879417b5bf9f5d827037a86439627a66b9c426 Mon Sep 17 00:00:00 2001 From: elong Date: Fri, 5 May 2017 09:18:22 -0400 Subject: [PATCH] 0003094: Status of batches set to resend when error on channel --- .../jumpmind/symmetric/service/impl/DataLoaderService.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java index 3db2fd5b8c..5c34d53cf2 100644 --- a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java +++ b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataLoaderService.java @@ -986,8 +986,8 @@ protected IDataWriter chooseDataWriter(Batch batch) { } resource.setState(State.DONE); } - } else { - log.info("The batch {} was missing in staging. Setting status to resend", batch.getNodeBatchId()); + } else if (resource == null || !resource.exists()) { + log.info("The batch {} was missing in staging. Setting status to resend.", batch.getNodeBatchId()); incomingBatch = new IncomingBatch(batch); incomingBatch.setStatus(Status.RS); incomingBatchService.updateIncomingBatch(incomingBatch);