diff --git a/source/client/src/clientEnv.c b/source/client/src/clientEnv.c index da24bc0a3b..212c42125e 100644 --- a/source/client/src/clientEnv.c +++ b/source/client/src/clientEnv.c @@ -555,6 +555,9 @@ static void *tscCrashReportThreadFp(void *param) { if (pFile) { taosReleaseCrashLogFile(pFile, false); pFile = NULL; + + taosMsleep(sleepTime); + loopTimes = 0; continue; } } else { diff --git a/source/dnode/mgmt/mgmt_dnode/src/dmWorker.c b/source/dnode/mgmt/mgmt_dnode/src/dmWorker.c index 18da1d638c..d6bdaf51bc 100644 --- a/source/dnode/mgmt/mgmt_dnode/src/dmWorker.c +++ b/source/dnode/mgmt/mgmt_dnode/src/dmWorker.c @@ -127,6 +127,9 @@ static void *dmCrashReportThreadFp(void *param) { if (pFile) { taosReleaseCrashLogFile(pFile, false); pFile = NULL; + + taosMsleep(sleepTime); + loopTimes = 0; continue; } } else { diff --git a/source/libs/executor/src/dynqueryctrloperator.c b/source/libs/executor/src/dynqueryctrloperator.c index 8fc46e0239..9e7f1144f8 100755 --- a/source/libs/executor/src/dynqueryctrloperator.c +++ b/source/libs/executor/src/dynqueryctrloperator.c @@ -503,15 +503,15 @@ static void seqJoinLaunchNewRetrieveImpl(SOperatorInfo* pOperator, SSDataBlock** T_LONG_JMP(pOperator->pTaskInfo->env, pOperator->pTaskInfo->code); } - qError("dynamic post task begin"); + qDebug("%s dynamic post task begin", GET_TASKID(pOperator->pTaskInfo)); *ppRes = pOperator->pDownstream[1]->fpSet.getNextExtFn(pOperator->pDownstream[1], pParam); if (*ppRes) { pPost->isStarted = true; pStbJoin->execInfo.postBlkNum++; pStbJoin->execInfo.postBlkRows += (*ppRes)->info.rows; - qError("join res block retrieved"); + qDebug("%s join res block retrieved", GET_TASKID(pOperator->pTaskInfo)); } else { - qError("Empty join res block retrieved"); + qDebug("%s Empty join res block retrieved", GET_TASKID(pOperator->pTaskInfo)); } }