removed separate threading for debugging purposes

polypheny · Dec 11, 2024 · 4d33a73 · 4d33a73
1 parent a8844a0
commit 4d33a73
Showing 1 changed file with 5 additions and 24 deletions.
diff --git a/dbms/src/main/java/org/polypheny/db/routing/UiRoutingPageUtil.java b/dbms/src/main/java/org/polypheny/db/routing/UiRoutingPageUtil.java
@@ -21,13 +21,8 @@
 import com.fasterxml.jackson.databind.node.ObjectNode;
 import com.google.common.collect.ImmutableList;
 import java.util.List;
-import java.util.concurrent.CompletionService;
-import java.util.concurrent.ExecutionException;
-import java.util.concurrent.ExecutorCompletionService;
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
-import java.util.concurrent.Future;
-import java.util.concurrent.ThreadPoolExecutor;
 import java.util.concurrent.atomic.AtomicInteger;
 import lombok.extern.slf4j.Slf4j;
 import org.polypheny.db.algebra.AlgNode;
@@ -81,25 +76,11 @@ public static void outputSingleResult( Plan plan, InformationManager queryAnalyz
 
 
     public static void addPhysicalPlanPage( AlgNode optimalNode, InformationManager queryAnalyzer, long stmtIdx, boolean attachTextualPlan ) {
-        UiRoutingPageUtil.counter.incrementAndGet();
-        Future<?> future = executorService.submit( () -> {
-            try {
-                addRoutedPolyPlanPage( optimalNode, queryAnalyzer, stmtIdx, true, attachTextualPlan );
-            } catch ( Throwable t ) {
-                log.error( "Error adding routing plan", t );
-            } finally {
-                UiRoutingPageUtil.counter.decrementAndGet();
-            }
-        } );
-
-        new Thread( () -> {
-            try {
-                future.get();
-            } catch ( InterruptedException | ExecutionException e ) {
-                log.error( "Future failed: Error adding routing plan", e );
-                throw new GenericRuntimeException( e );
-            }
-        });
+        try {
+            addRoutedPolyPlanPage( optimalNode, queryAnalyzer, stmtIdx, true, attachTextualPlan );
+        } catch ( Throwable t ) {
+            log.error( "Error adding routing plan", t );
+        }
     }