diff --git a/source/libs/stream/src/streamTask.c b/source/libs/stream/src/streamTask.c index 5d725b012c..c7fb86d556 100644 --- a/source/libs/stream/src/streamTask.c +++ b/source/libs/stream/src/streamTask.c @@ -1034,7 +1034,7 @@ static int32_t streamTaskCompleteCheckRsp(STaskCheckInfo* pInfo, const char* id) pInfo->startTs = 0; pInfo->notReadyTasks = 0; pInfo->inCheckProcess = 0; - pInfo->stopCheckProcess = 1; + pInfo->stopCheckProcess = 0; taosArrayClear(pInfo->pList); return 0;