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

the same time during a pull
JumpMind · Sep 19, 2017 · a81d340 · a81d340
1 parent cd21af9
commit a81d340
Showing 1 changed file with 4 additions and 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
@@ -167,7 +167,7 @@ public class DataLoaderService extends AbstractService implements IDataLoaderSer
 
     private Date lastUpdateTime;
 
-    private CustomizableThreadFactory threadFactory = new CustomizableThreadFactory("dataloader");
+    private CustomizableThreadFactory threadFactory;
 
     public DataLoaderService(ISymmetricEngine engine) {
         super(engine.getParameterService(), engine.getSymmetricDialect());
@@ -550,7 +550,9 @@ protected List<IncomingBatch> loadDataFromTransport(final ProcessInfo processInf
             String targetNodeId = nodeService.findIdentityNodeId();
             if (parameterService.is(ParameterConstants.STREAM_TO_FILE_ENABLED)) {
                 processInfo.setStatus(ProcessInfo.Status.TRANSFERRING);
-                //ExecutorService executor = Executors.newFixedThreadPool(1, new UniqueThreadFactory("dataloader"));
+                if (threadFactory == null) {
+                    threadFactory = new CustomizableThreadFactory(parameterService.getEngineName().toLowerCase() + "-dataloader");
+                }
                 ExecutorService executor = Executors.newFixedThreadPool(1, threadFactory);
                 LoadIntoDatabaseOnArrivalListener loadListener = new LoadIntoDatabaseOnArrivalListener(processInfo,
                         sourceNode.getNodeId(), listener, executor);