xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

refactor(stream): drop task in async ways

This commit is contained in:
Haojun Liao 2025-02-13 23:43:07 +08:00
parent fd96b096ea
commit 43d45e9f9a
2 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/dnode/vnode/src/tqCommon/tqCommon.c
View File

@ -720,7 +720,7 @@ int32_t tqStreamTaskProcessDropReq(SStreamMeta* pMeta, SMsgCb* cb, char* msg, in
// drop the related fill-history task firstly // drop the related fill-history task firstly
if (hTaskId.taskId != 0 && hTaskId.streamId != 0) { if (hTaskId.taskId != 0 && hTaskId.streamId != 0) {
code = streamTaskSchedTask(cb, vgId, hTaskId.streamId, hTaskId.taskId, STREAM_EXEC_T_DROP_ONE_TASK); code = streamTaskSchedTask(cb, vgId, hTaskId.streamId, (int32_t)hTaskId.taskId, STREAM_EXEC_T_DROP_ONE_TASK);
if (code) { if (code) {
tqError("s-task:0x%x vgId:%d failed to create msg to drop rel fill-history task:0x%x, code:%s", pReq->taskId, tqError("s-task:0x%x vgId:%d failed to create msg to drop rel fill-history task:0x%x, code:%s", pReq->taskId,
vgId, (int32_t)hTaskId.taskId, tstrerror(code)); vgId, (int32_t)hTaskId.taskId, tstrerror(code));

2
tests/ci/func.txt
View File

@ -79,7 +79,7 @@
(void)streamMetaAddFailedTask (void)streamMetaAddFailedTask
(void)streamMetaAddTaskLaunchResult (void)streamMetaAddTaskLaunchResult
(void)streamMetaCommit (void)streamMetaCommit
(void)streamMetaRemoveTask (void)streamMetaRemoveTaskInMeta
(void)streamMetaSendHbHelper (void)streamMetaSendHbHelper
(void)streamMetaStartAllTasks (void)streamMetaStartAllTasks
(void)streamMetaStartOneTask (void)streamMetaStartOneTask