From 7cf0add513d812c687a83bb1712ef53830d2a234 Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Thu, 14 Dec 2023 11:28:03 +0800 Subject: [PATCH] fix(stream): fix error caused by refactor. --- source/dnode/vnode/src/tq/tq.c | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/source/dnode/vnode/src/tq/tq.c b/source/dnode/vnode/src/tq/tq.c index 4834924fe0..138c58b45f 100644 --- a/source/dnode/vnode/src/tq/tq.c +++ b/source/dnode/vnode/src/tq/tq.c @@ -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) {