From 8392c99d36435173532dd61a9df7ffa2c374b078 Mon Sep 17 00:00:00 2001 From: yihaoDeng Date: Fri, 13 Oct 2023 14:54:00 +0800 Subject: [PATCH] refactor backend --- source/dnode/vnode/src/tq/tq.c | 28 ++++++++++++++-------------- 1 file changed, 14 insertions(+), 14 deletions(-) diff --git a/source/dnode/vnode/src/tq/tq.c b/source/dnode/vnode/src/tq/tq.c index fbd8a3ee05..778a01719f 100644 --- a/source/dnode/vnode/src/tq/tq.c +++ b/source/dnode/vnode/src/tq/tq.c @@ -748,14 +748,14 @@ int32_t tqExpandTask(STQ* pTq, SStreamTask* pTask, int64_t ver) { if (pTask->info.taskLevel == TASK_LEVEL__SOURCE) { SStreamTask* pStateTask = pTask; - SStreamTask task = {0}; - if (pTask->info.fillHistory) { - task.id = pTask->streamTaskId; - task.pMeta = pTask->pMeta; - pStateTask = &task; - } + // SStreamTask task = {0}; + // if (pTask->info.fillHistory) { + // task.id = pTask->streamTaskId; + // task.pMeta = pTask->pMeta; + // pStateTask = &task; + // } - pTask->pState = streamStateOpen(pTq->pStreamMeta->path, pStateTask, false, -1, -1); + pTask->pState = streamStateOpen(pTq->pStreamMeta->path, pTask, false, -1, -1); if (pTask->pState == NULL) { tqError("s-task:%s (vgId:%d) failed to open state for task", pTask->id.idStr, vgId); return -1; @@ -782,14 +782,14 @@ int32_t tqExpandTask(STQ* pTq, SStreamTask* pTask, int64_t ver) { qSetTaskId(pTask->exec.pExecutor, pTask->id.taskId, pTask->id.streamId); } else if (pTask->info.taskLevel == TASK_LEVEL__AGG) { SStreamTask* pSateTask = pTask; - SStreamTask task = {0}; - if (pTask->info.fillHistory) { - task.id = pTask->streamTaskId; - task.pMeta = pTask->pMeta; - pSateTask = &task; - } + // SStreamTask task = {0}; + // if (pTask->info.fillHistory) { + // task.id = pTask->streamTaskId; + // task.pMeta = pTask->pMeta; + // pSateTask = &task; + // } - pTask->pState = streamStateOpen(pTq->pStreamMeta->path, pSateTask, false, -1, -1); + pTask->pState = streamStateOpen(pTq->pStreamMeta->path, pTask, false, -1, -1); if (pTask->pState == NULL) { tqError("s-task:%s (vgId:%d) failed to open state for task", pTask->id.idStr, vgId); return -1;