fix:conflicts from 3.0

This commit is contained in:
wangmm0220 2024-09-13 15:25:01 +08:00
parent 478414c32d
commit 44e2905983
1 changed files with 2 additions and 1 deletions

View File

@ -767,7 +767,8 @@ static void* monitorThreadFunc(void* param) {
}
MonitorSlowLogData* slowLogData = NULL;
if (taosReadQitem(monitorQueue, (void**)&slowLogData) != 0) {
taosReadQitem(monitorQueue, (void**)&slowLogData);
if (slowLogData != NULL) {
if (slowLogData->type == SLOW_LOG_READ_BEGINNIG && quitCnt == 0) {
if (slowLogData->pFile != NULL) {
monitorSendSlowLogAtBeginning(slowLogData->clusterId, &(slowLogData->fileName), slowLogData->pFile,