From 9a7fec10afc3c4d835a6c6f288e446a5deaef85c Mon Sep 17 00:00:00 2001 From: dapan1121 Date: Fri, 27 Sep 2024 13:32:28 +0800 Subject: [PATCH] fix: task reschedule issue --- source/libs/scheduler/src/schTask.c | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/source/libs/scheduler/src/schTask.c b/source/libs/scheduler/src/schTask.c index a0275d9c21..3a63889271 100644 --- a/source/libs/scheduler/src/schTask.c +++ b/source/libs/scheduler/src/schTask.c @@ -358,6 +358,11 @@ int32_t schRescheduleTask(SSchJob *pJob, SSchTask *pTask) { int32_t schChkUpdateRedirectCtx(SSchJob *pJob, SSchTask *pTask, SEpSet *pEpSet, int32_t rspCode) { SSchRedirectCtx *pCtx = &pTask->redirectCtx; + if (JOB_TASK_STATUS_EXEC == pTask->status) { + SCH_TASK_DLOG("task not start yet, rspCode:%d", rspCode); + return TSDB_CODE_SUCCESS; + } + if (!pCtx->inRedirect) { pCtx->inRedirect = true; pCtx->periodMs = tsRedirectPeriod;