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

fix(stream): fix syntax error.

This commit is contained in:
Haojun Liao 2024-09-09 15:51:25 +08:00
parent f2cb9b3bb9
commit 68e3beac0e
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/dnode/vnode/src/vnd/vnodeSync.c
View File

@ -589,7 +589,7 @@ static void vnodeRestoreFinish(const SSyncFSM *pFsm, const SyncIndex commitIdx)
tqInfo("vgId:%d stream task already loaded, start them", vgId); tqInfo("vgId:%d stream task already loaded, start them", vgId);
int32_t code = streamTaskSchedTask(&pVnode->msgCb, TD_VID(pVnode), 0, 0, STREAM_EXEC_T_START_ALL_TASKS); int32_t code = streamTaskSchedTask(&pVnode->msgCb, TD_VID(pVnode), 0, 0, STREAM_EXEC_T_START_ALL_TASKS);
if (code != 0) { if (code != 0) {
tqError("vgId:%^d failed to sched stream task, code:%s", vgId, tstrerror(code)); tqError("vgId:%d failed to sched stream task, code:%s", vgId, tstrerror(code));
} }
return; return;
} }