0003792: Routing bottleneck on long routing runs (fix connection leak)

JumpMind · Apr 15, 2019 · 1a05a3d · 1a05a3d
1 parent 89d17f9
commit 1a05a3d
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/route/DataGapRouteReader.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/route/DataGapRouteReader.java
@@ -146,6 +146,10 @@ protected void execute() {
                     .equals(NonTransactionalBatchAlgorithm.NAME)
                     || !symmetricDialect.supportsTransactionId();
 
+            processInfo.setStatus(ProcessStatus.QUERYING);
+            cursor = prepareCursor();
+            processInfo.setStatus(ProcessStatus.EXTRACTING);            
+
             if (transactional) {
                 executeTransactional(cursor);
             } else {
@@ -182,9 +186,6 @@ protected void executeTransactional(ISqlReadCursor<Data> cursor) throws Exceptio
         long maxDataToRoute = context.getChannel().getMaxDataToRoute();
         List<Data> peekAheadQueue = new ArrayList<Data>(peekAheadCount);
 
-        processInfo.setStatus(ProcessStatus.QUERYING);
-        cursor = prepareCursor();
-        processInfo.setStatus(ProcessStatus.EXTRACTING);
         boolean moreData = true;
         while (dataCount < maxDataToRoute || (lastTransactionId != null)) {
             if (moreData && (lastTransactionId != null || peekAheadQueue.size() == 0)) {