fix(stream): not wait for the timer stopped.
This commit is contained in:
parent
f82505ba16
commit
fb58ca8592
|
@ -375,10 +375,7 @@ void tFreeStreamTask(SStreamTask* pTask) {
|
||||||
}
|
}
|
||||||
|
|
||||||
if (pTask->schedInfo.pDelayTimer != NULL) {
|
if (pTask->schedInfo.pDelayTimer != NULL) {
|
||||||
while(!taosTmrStop(pTask->schedInfo.pDelayTimer)) {
|
taosTmrStop(pTask->schedInfo.pDelayTimer);
|
||||||
stError("failed to stop the trigger sched timer, wait for 100ms and retry");
|
|
||||||
taosMsleep(100);
|
|
||||||
}
|
|
||||||
pTask->schedInfo.pDelayTimer = NULL;
|
pTask->schedInfo.pDelayTimer = NULL;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue