improve maxTransportThreads

apache · Sep 26, 2021 · e1baca9 · e1baca9
1 parent 9c652d8
commit e1baca9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/TransportConf.java b/computer-core/src/main/java/com/baidu/hugegraph/computer/core/network/TransportConf.java
@@ -76,7 +76,7 @@ private int maxTransportThreads() {
                                   .get(ComputerOptions.JOB_WORKERS_COUNT);
         Integer partitions = this.config
                                  .get(ComputerOptions.JOB_PARTITIONS_COUNT);
-        return partitions / workerCount;
+        return partitions / workerCount + 1;
     }
 
     public TransportProvider transportProvider() {