From 1b343e662c0ac1e74bd731935b77b67f4be9349e Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Sun, 7 Apr 2024 10:18:01 +0800
Subject: [PATCH] fix(stream): retry stop timer for trigger tmr.

---
 source/libs/stream/src/streamTask.c | 11 ++++++++---
 1 file changed, 8 insertions(+), 3 deletions(-)

diff --git a/source/libs/stream/src/streamTask.c b/source/libs/stream/src/streamTask.c
index c7a1a00a46..c610e86322 100644
--- a/source/libs/stream/src/streamTask.c
+++ b/source/libs/stream/src/streamTask.c
@@ -375,17 +375,22 @@ void tFreeStreamTask(SStreamTask* pTask) {
   }
 
   if (pTask->schedInfo.pDelayTimer != NULL) {
-    taosTmrStop(pTask->schedInfo.pDelayTimer);
+    while(!taosTmrStop(pTask->schedInfo.pDelayTimer)) {
+      stError("failed to stop the trigger sched timer, wait for 100ms and retry");
+      taosMsleep(100);
+    }
     pTask->schedInfo.pDelayTimer = NULL;
   }
 
   if (pTask->hTaskInfo.pTimer != NULL) {
-    taosTmrStop(pTask->hTaskInfo.pTimer);
+    bool ret = taosTmrStop(pTask->hTaskInfo.pTimer);
+    ASSERT(ret);
     pTask->hTaskInfo.pTimer = NULL;
   }
 
   if (pTask->msgInfo.pTimer != NULL) {
-    taosTmrStop(pTask->msgInfo.pTimer);
+    bool ret = taosTmrStop(pTask->msgInfo.pTimer);
+    ASSERT(ret);
     pTask->msgInfo.pTimer = NULL;
   }