diff --git a/source/dnode/vnode/src/tqCommon/tqCommon.c b/source/dnode/vnode/src/tqCommon/tqCommon.c index 2b86ec8264..efd847a1f3 100644 --- a/source/dnode/vnode/src/tqCommon/tqCommon.c +++ b/source/dnode/vnode/src/tqCommon/tqCommon.c @@ -1011,10 +1011,16 @@ int32_t tqStreamTaskProcessAllTaskStopReq(SStreamMeta* pMeta, SMsgCb* pMsgCb, SR // stop all stream tasks, only invoked when trying to drop db if (req.streamId <= 0) { tqDebug("vgId:%d recv msg to stop all tasks in sync before dropping vnode", vgId); - streamMetaStopAllTasks(pMeta); + code = streamMetaStopAllTasks(pMeta); + if (code) { + tqError("vgId:%d failed to stop all tasks, code:%s", vgId, tstrerror(code)); + } + } else { // stop only one stream tasks } + + // always return success return TSDB_CODE_SUCCESS; } diff --git a/tests/ci/func.txt b/tests/ci/func.txt index 45d4fb1c11..52df0aad96 100644 --- a/tests/ci/func.txt +++ b/tests/ci/func.txt @@ -409,7 +409,7 @@ (void)tqProcessTaskConsenChkptIdReq (void)tqProcessTaskResetReq (void)tqScanWalAsync -(void)tqStopStreamTasksAsync +(void)tqStopStreamAllTasksAsync (void)tqUpdateTbUidList (void)transAcquireExHandle (void)transAsyncSend