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 2025-02-22 14:16:46 +08:00
parent 9bd8b532ad
commit 6c92474afd
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/dnode/vnode/src/tq/tqStreamTask.c
View File

@ -156,13 +156,13 @@ void tqScanWalAsync(STQ* pTq) {
// 2. the stream isn't disabled // 2. the stream isn't disabled
if ((pMeta->role == NODE_ROLE_FOLLOWER) || tsDisableStream) { if ((pMeta->role == NODE_ROLE_FOLLOWER) || tsDisableStream) {
tqInfo("vgId:%d follower node or stream disabled, not scan wal", vgId); tqInfo("vgId:%d follower node or stream disabled, not scan wal", vgId);
return TSDB_CODE_SUCCESS; return;
} }
pParam = taosMemoryMalloc(sizeof(SBuildScanWalMsgParam)); pParam = taosMemoryMalloc(sizeof(SBuildScanWalMsgParam));
if (pParam == NULL) { if (pParam == NULL) {
tqError("vgId:%d failed to start scan wal, stream not executes, code:%s", vgId, tstrerror(code)); tqError("vgId:%d failed to start scan wal, stream not executes, code:%s", vgId, tstrerror(code));
return terrno; return;
} }
pParam->metaId = pMeta->rid; pParam->metaId = pMeta->rid;

2
source/dnode/vnode/src/tq/tqUtil.c
View File

@ -49,7 +49,7 @@ void tqUpdateNodeStage(STQ* pTq, bool isLeader) {
streamMetaUpdateStageRole(pTq->pStreamMeta, state.term, isLeader); streamMetaUpdateStageRole(pTq->pStreamMeta, state.term, isLeader);
if (isLeader) { if (isLeader) {
int32_t code = tqScanWalAsync(pTq); tqScanWalAsync(pTq);
} }
} }