diff --git a/source/client/src/clientEnv.c b/source/client/src/clientEnv.c index 7f83c573eabae7207f46834216fbbf65b593d967..79c5baf43d8971d2e4384ddec6ce3c92a14c25bc 100644 --- a/source/client/src/clientEnv.c +++ b/source/client/src/clientEnv.c @@ -84,7 +84,6 @@ static void deregisterRequest(SRequestObj *pRequest) { pRequest->self, pTscObj->id, pRequest->requestId, duration / 1000.0, num, currentInst); if (pRequest->pQuery && pRequest->pQuery->pRoot) { - if (QUERY_NODE_VNODE_MODIFY_STMT == pRequest->pQuery->pRoot->type && (0 == ((SVnodeModifyOpStmt *)pRequest->pQuery->pRoot)->sqlNodeType)) { tscDebug("insert duration %" PRId64 "us: parseCost:%" PRId64 "us, ctgCost:%" PRId64 "us, analyseCost:%" PRId64 @@ -160,7 +159,7 @@ void *openTransporter(const char *user, const char *auth, int32_t numOfThread) { rpcInit.retryMaxInterval = tsRedirectMaxPeriod; rpcInit.retryMaxTimouet = tsMaxRetryWaitTime; - int32_t connLimitNum = tsNumOfRpcSessions / (tsNumOfRpcThreads * 3); + int32_t connLimitNum = tsNumOfRpcSessions / (tsNumOfRpcThreads * 5); connLimitNum = TMAX(connLimitNum, 10); connLimitNum = TMIN(connLimitNum, 500); rpcInit.connLimitNum = connLimitNum; @@ -524,7 +523,7 @@ void taos_init_imp(void) { if (code) { printf("failed to init memory dbg, error:%s\n", tstrerror(code)); } else { - tsAsyncLog = false; + tsAsyncLog = false; printf("memory dbg enabled\n"); } } diff --git a/source/common/src/tglobal.c b/source/common/src/tglobal.c index 2275345d7fcd6560201f7e047ff4cecdfd77e5c0..99795fcc794ecf875497abf3bb180cfd92e4919d 100644 --- a/source/common/src/tglobal.c +++ b/source/common/src/tglobal.c @@ -41,8 +41,8 @@ bool tsPrintAuth = false; // queue & threads int32_t tsNumOfRpcThreads = 1; -int32_t tsNumOfRpcSessions = 10000; -int32_t tsTimeToGetAvailableConn = 10000; +int32_t tsNumOfRpcSessions = 5000; +int32_t tsTimeToGetAvailableConn = 100000; int32_t tsNumOfCommitThreads = 2; int32_t tsNumOfTaskQueueThreads = 4; int32_t tsNumOfMnodeQueryThreads = 4;