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

fix(stream): fix send msg error.

This commit is contained in:
Haojun Liao 2023-11-15 16:31:07 +08:00
parent c70c54a099
commit 81d3e5737e
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/libs/stream/src/streamDispatch.c
View File

@ -1159,7 +1159,7 @@ int32_t streamProcessDispatchRsp(SStreamTask* pTask, SStreamDispatchRsp* pRsp, i
{ // send checkpoint failure msg to mnode directly { // send checkpoint failure msg to mnode directly
pTask->chkInfo.failedId = pTask->checkpointingId; // record the latest failed checkpoint id pTask->chkInfo.failedId = pTask->checkpointingId; // record the latest failed checkpoint id
pTask->checkpointingId = pTask->checkpointingId; pTask->checkpointingId = pTask->checkpointingId;
streamTaskSendCheckpointReadyMsg(pTask); streamTaskSendCheckpointSourceRsp(pTask);
} }
} else { } else {
stError("s-task:%s downstream task:0x%x(vgId:%d) refused the dispatch msg, treat it as success", id, stError("s-task:%s downstream task:0x%x(vgId:%d) refused the dispatch msg, treat it as success", id,