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

fix(stream): fix the not running bug.

This commit is contained in:
Haojun Liao 2024-01-03 18:28:23 +08:00
parent 4138692cea
commit 4399867e14
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/tq/tq.c
View File

@ -1074,7 +1074,7 @@ int32_t tqProcessTaskRunReq(STQ* pTq, SRpcMsg* pMsg) {
int32_t code = tqStreamTaskProcessRunReq(pTq->pStreamMeta, pMsg, vnodeIsRoleLeader(pTq->pVnode)); int32_t code = tqStreamTaskProcessRunReq(pTq->pStreamMeta, pMsg, vnodeIsRoleLeader(pTq->pVnode));
// let's continue scan data in the wal files // let's continue scan data in the wal files
if(code == 0 && pReq->reqType > 0){ if(code == 0 && pReq->reqType >= 0){
tqScanWalAsync(pTq, false); tqScanWalAsync(pTq, false);
} }