From 65aa86edec350b78cedd95cd50282a54b9fe5693 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Tue, 29 Nov 2022 10:11:34 +0800 Subject: [PATCH] change paramter --- source/common/src/tglobal.c | 2 +- source/libs/transport/src/transCli.c | 3 ++- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/source/common/src/tglobal.c b/source/common/src/tglobal.c index cb82ad300b..02703dd0a1 100644 --- a/source/common/src/tglobal.c +++ b/source/common/src/tglobal.c @@ -88,7 +88,7 @@ int32_t tsQueryNodeChunkSize = 32 * 1024; bool tsQueryUseNodeAllocator = true; bool tsKeepColumnName = false; int32_t tsRedirectPeriod = 100; -int32_t tsRedirectFactor = 5; +int32_t tsRedirectFactor = 1; int32_t tsRedirectMaxPeriod = 10000; int32_t tsMaxRetryWaitTime = 60000; diff --git a/source/libs/transport/src/transCli.c b/source/libs/transport/src/transCli.c index d0b8adeffe..429dc80622 100644 --- a/source/libs/transport/src/transCli.c +++ b/source/libs/transport/src/transCli.c @@ -1444,6 +1444,7 @@ bool cliResetEpset(STransConnCtx* pCtx, STransMsg* pResp, bool hasEpSet) { if (!transEpSetIsEqual(&pCtx->epSet, &epSet)) { tDebug("epset not equal, retry new epset"); pCtx->epSet = epSet; + noDelay = false; } else { if (pCtx->epsetRetryCnt >= pCtx->epSet.numOfEps) { noDelay = false; @@ -1475,7 +1476,7 @@ bool cliGenRetryRule(SCliConn* pConn, STransMsg* pResp, SCliMsg* pMsg) { pCtx->retryMaxTimeout = pTransInst->retryMaxTimouet; pCtx->retryInitTimestamp = taosGetTimestampMs(); pCtx->retryNextInterval = pCtx->retryMinInterval; - pCtx->retryStep = 1; + pCtx->retryStep = 0; pCtx->retryInit = true; } if (-1 != pCtx->retryMaxTimeout && taosGetTimestampMs() - pCtx->retryInitTimestamp >= pCtx->retryMaxTimeout) {