From 402a43bf67143a71521dfdafbdc0c4f9a084be50 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Tue, 27 Feb 2024 11:25:32 +0800 Subject: [PATCH] fix(stream): disable halt. --- source/dnode/vnode/src/tq/tq.c | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/source/dnode/vnode/src/tq/tq.c b/source/dnode/vnode/src/tq/tq.c index e279b4bc1d..011e62cb89 100644 --- a/source/dnode/vnode/src/tq/tq.c +++ b/source/dnode/vnode/src/tq/tq.c @@ -1178,7 +1178,7 @@ int32_t tqProcessTaskCheckPointSourceReq(STQ* pTq, SRpcMsg* pMsg, SRpcMsg* pRsp) // ASSERT(status == TASK_STATUS__HALT); if (status != TASK_STATUS__HALT) { tqError("s-task:%s should in halt status, let's halt it directly", pTask->id.idStr); - streamTaskHandleEvent(pTask->status.pSM, TASK_EVENT_HALT); +// streamTaskHandleEvent(pTask->status.pSM, TASK_EVENT_HALT); } }