diff --git a/computer-core/src/main/java/org/apache/hugegraph/computer/core/input/WorkerInputManager.java b/computer-core/src/main/java/org/apache/hugegraph/computer/core/input/WorkerInputManager.java index f4c432b73..7cacb9663 100644 --- a/computer-core/src/main/java/org/apache/hugegraph/computer/core/input/WorkerInputManager.java +++ b/computer-core/src/main/java/org/apache/hugegraph/computer/core/input/WorkerInputManager.java @@ -111,7 +111,7 @@ public void loadGraph() { } CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).exceptionally(e -> { throw new ComputerException("An exception occurred during parallel " + - "sending vertices", e); + "sending vertices", e); }).join(); this.sendManager.finishSend(MessageType.VERTEX); @@ -124,7 +124,7 @@ public void loadGraph() { } CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).exceptionally(e -> { throw new ComputerException("An exception occurred during parallel " + - "sending edges", e); + "sending edges", e); }).join(); this.sendManager.finishSend(MessageType.EDGE); this.sendManager.clearBuffer();