You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2020/06/11 08:57:58 UTC
[incubator-iotdb] branch thrift_test updated: add param
This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a commit to branch thrift_test
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
The following commit(s) were added to refs/heads/thrift_test by this push:
new 9d0aec6 add param
9d0aec6 is described below
commit 9d0aec68bc4b3c568287543cc38320be7fbfc79b
Author: jt2594838 <jt...@163.com>
AuthorDate: Thu Jun 11 16:57:41 2020 +0800
add param
---
server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java b/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
index 57284d0..8231661 100644
--- a/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
+++ b/server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
@@ -1496,7 +1496,7 @@ public class TSServiceImpl implements TSIService.Iface, ServerContext {
AtomicInteger globalCnt = new AtomicInteger();
long startTime = System.currentTimeMillis();
- int clientNum = 50;
+ int clientNum = Integer.parseInt(args[2]);
ExecutorService pool = Executors.newFixedThreadPool(clientNum);
for (int i = 0; i < clientNum; i++) {
pool.submit(() -> {