diff --git a/jvector-base/src/main/java/io/github/jbellis/jvector/graph/GraphIndexBuilder.java b/jvector-base/src/main/java/io/github/jbellis/jvector/graph/GraphIndexBuilder.java index 06415b1c4..040419d84 100644 --- a/jvector-base/src/main/java/io/github/jbellis/jvector/graph/GraphIndexBuilder.java +++ b/jvector-base/src/main/java/io/github/jbellis/jvector/graph/GraphIndexBuilder.java @@ -243,7 +243,7 @@ private void reconnectOrphanedNodes() { // reconnect unreachable nodes var nReconnected = new AtomicInteger(); var connectionTargets = ConcurrentHashMap.newKeySet(); - parallelExecutor.submit(() -> IntStream.range(0, graph.getIdUpperBound()).parallel().forEach(node -> { + simdExecutor.submit(() -> IntStream.range(0, graph.getIdUpperBound()).parallel().forEach(node -> { if (connectedNodes.get(node) || !graph.containsNode(node)) { return; }