From a9abe78eab4fc622d34aa005913043fade07258e Mon Sep 17 00:00:00 2001
From: Haojun Liao <hjliao@taosdata.com>
Date: Wed, 29 May 2024 09:16:37 +0800
Subject: [PATCH] other: comment invalid sleep for test purpose

---
 source/libs/stream/src/streamCheckpoint.c | 3 ++-
 source/libs/stream/src/streamExec.c       | 2 +-
 2 files changed, 3 insertions(+), 2 deletions(-)

diff --git a/source/libs/stream/src/streamCheckpoint.c b/source/libs/stream/src/streamCheckpoint.c
index 414c4e2a76..756183a624 100644
--- a/source/libs/stream/src/streamCheckpoint.c
+++ b/source/libs/stream/src/streamCheckpoint.c
@@ -196,9 +196,10 @@ int32_t streamProcessCheckpointTriggerBlock(SStreamTask* pTask, SStreamDataBlock
     }
 
     int32_t ref = atomic_add_fetch_32(&pTask->status.timerActive, 1);
-    stDebug("s-task:%s start check-rsp monitor in 10s, ref:%d ", pTask->id.idStr, ref);
+    stDebug("s-task:%s start checkpoint-trigger monitor in 10s, ref:%d ", pTask->id.idStr, ref);
     SActiveCheckpointInfo* pActive = pTask->chkInfo.pActiveInfo;
     if (pActive->pCheckTmr == NULL) {
+      streamMetaAcquireOneTask(pTask);
       pActive->pCheckTmr = taosTmrStart(checkpointTriggerMonitorFn, 100, pTask, streamTimer);
     } else {
       taosTmrReset(checkpointTriggerMonitorFn, 100, pTask, streamTimer, &pActive->pCheckTmr);
diff --git a/source/libs/stream/src/streamExec.c b/source/libs/stream/src/streamExec.c
index 1e85b959a8..2b92696b88 100644
--- a/source/libs/stream/src/streamExec.c
+++ b/source/libs/stream/src/streamExec.c
@@ -598,7 +598,7 @@ static int32_t doStreamExecTask(SStreamTask* pTask) {
     int32_t type = pInput->type;
     if (type == STREAM_INPUT__CHECKPOINT_TRIGGER) {
       if (pTask->pMeta->vgId == 2) {
-        taosSsleep(20);
+//        taosSsleep(20);
       }
 
       streamProcessCheckpointTriggerBlock(pTask, (SStreamDataBlock*)pInput);