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

fix(stream): fix error caused by refactor.

This commit is contained in:
Haojun Liao 2023-12-14 11:28:03 +08:00
parent 38d7ae3cd7
commit 7cf0add513
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -713,8 +713,8 @@ static STaskId replaceStreamTaskId(SStreamTask* pTask) {
static void restoreStreamTaskId(SStreamTask* pTask, STaskId* pId) {
ASSERT(pTask->info.fillHistory);
pTask->streamTaskId.taskId = pId->taskId;
pTask->streamTaskId.streamId = pId->streamId;
pTask->id.taskId = pId->taskId;
pTask->id.streamId = pId->streamId;
}
int32_t tqExpandTask(STQ* pTq, SStreamTask* pTask, int64_t nextProcessVer) {