0003762: Jdbc Batch bulk data loader causes missing rows on initial load

JumpMind · Oct 24, 2018 · 1e69027 · 1e69027
1 parent 00c474c
commit 1e69027
Showing 1 changed file with 10 additions and 1 deletion.
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
@@ -1047,7 +1047,16 @@ protected IDataWriter chooseDataWriter(Batch batch) {
                                 ctx.put(ContextConstants.CONTEXT_BULK_WRITER_TO_USE, "default");
                                 listener.currentBatch.setStatus(Status.OK);
                                 processor.setDataReader(buildDataReader(batchInStaging, resource));
-                                processor.process(ctx);
+                                try {
+                                    listener.getBatchesProcessed().remove(listener.currentBatch);
+                                    processor.process(ctx);
+                                } catch (Exception retryException) {
+                                    isError = true;
+                                    incomingBatch = listener.currentBatch;
+                                    incomingBatch.setStatus(Status.ER);
+                                    incomingBatchService.updateIncomingBatch(incomingBatch);
+                                    throw e;
+                                }
                             } else {
                                 isError = true;
                                 throw e;