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

fix: level task done number issue

This commit is contained in:
dapan1121 2024-06-20 14:21:33 +08:00
parent 0a8a3d15bc
commit c9d847787e
1 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
source/libs/scheduler/src/schTask.c
View File

@ -248,7 +248,7 @@ int32_t schProcessOnTaskSuccess(SSchJob *pJob, SSchTask *pTask) {
SCH_LOG_TASK_END_TS(pTask); SCH_LOG_TASK_END_TS(pTask);
atomic_add_fetch_32(&pTask->level->taskExecDoneNum, 1); int32_t taskDone = atomic_add_fetch_32(&pTask->level->taskExecDoneNum, 1);
SCH_SET_TASK_STATUS(pTask, JOB_TASK_STATUS_PART_SUCC); SCH_SET_TASK_STATUS(pTask, JOB_TASK_STATUS_PART_SUCC);
@ -319,8 +319,10 @@ int32_t schProcessOnTaskSuccess(SSchJob *pJob, SSchTask *pTask) {
} }
} }
SCH_ERR_RET(schLaunchJobLowerLevel(pJob, pTask)); if (taskDone == pTask->level->taskNum) {
SCH_ERR_RET(schLaunchJobLowerLevel(pJob, pTask));
}
return TSDB_CODE_SUCCESS; return TSDB_CODE_SUCCESS;
} }