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) {