xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Merge pull request #23805 from taosdata/fix/slowReport 

fix: slow down report when error occurs
This commit is contained in:
dapan1121 2023-11-24 09:18:27 +08:00 committed by GitHub
parent 95b5fbbb1a 699c14e781
commit 26fe05bb30
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
source/client/src/clientEnv.c
View File

@ -555,6 +555,9 @@ static void *tscCrashReportThreadFp(void *param) {
if (pFile) { if (pFile) {
taosReleaseCrashLogFile(pFile, false); taosReleaseCrashLogFile(pFile, false);
pFile = NULL; pFile = NULL;
taosMsleep(sleepTime);
loopTimes = 0;
continue; continue;
} }
} else { } else {

3
source/dnode/mgmt/mgmt_dnode/src/dmWorker.c
View File

@ -127,6 +127,9 @@ static void *dmCrashReportThreadFp(void *param) {
if (pFile) { if (pFile) {
taosReleaseCrashLogFile(pFile, false); taosReleaseCrashLogFile(pFile, false);
pFile = NULL; pFile = NULL;
taosMsleep(sleepTime);
loopTimes = 0;
continue; continue;
} }
} else { } else {

6
source/libs/executor/src/dynqueryctrloperator.c
View File

@ -503,15 +503,15 @@ static void seqJoinLaunchNewRetrieveImpl(SOperatorInfo* pOperator, SSDataBlock**
T_LONG_JMP(pOperator->pTaskInfo->env, pOperator->pTaskInfo->code); 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); *ppRes = pOperator->pDownstream[1]->fpSet.getNextExtFn(pOperator->pDownstream[1], pParam);
if (*ppRes) { if (*ppRes) {
pPost->isStarted = true; pPost->isStarted = true;
pStbJoin->execInfo.postBlkNum++; pStbJoin->execInfo.postBlkNum++;
pStbJoin->execInfo.postBlkRows += (*ppRes)->info.rows; pStbJoin->execInfo.postBlkRows += (*ppRes)->info.rows;
qError("join res block retrieved"); qDebug("%s join res block retrieved", GET_TASKID(pOperator->pTaskInfo));
} else { } else {
qError("Empty join res block retrieved"); qDebug("%s Empty join res block retrieved", GET_TASKID(pOperator->pTaskInfo));
} }
} }