0003239: Observed that two load threads are loading the same batch at

the same time during a pull
JumpMind · Sep 5, 2017 · e0a3589 · e0a3589
1 parent ddd4b62
commit e0a3589
Showing 1 changed file with 5 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
@@ -569,7 +569,11 @@ protected List<IncomingBatch> loadDataFromTransport(final ProcessInfo processInf
                         outWriter.flush();
                     }
                 } else {
-                    executor.awaitTermination(12, TimeUnit.HOURS);           
+                    long hours = 1;
+                    while (!executor.awaitTermination(1, TimeUnit.HOURS)) {
+                        log.info(String.format("Executor has been awaiting loader termination for %d hour(s).", hours));
+                        hours++;
+                    }            
                 }
 
                 loadListener.isDone();