From 23098a08cf2bb3152bd2085eb281b251c2bbef86 Mon Sep 17 00:00:00 2001 From: Cary Xu Date: Wed, 24 Aug 2022 18:18:53 +0800 Subject: [PATCH] other: revert to 3.0 --- source/dnode/vnode/src/tq/tq.c | 5 ----- 1 file changed, 5 deletions(-) diff --git a/source/dnode/vnode/src/tq/tq.c b/source/dnode/vnode/src/tq/tq.c index 7440c03767..3ff59ac2c0 100644 --- a/source/dnode/vnode/src/tq/tq.c +++ b/source/dnode/vnode/src/tq/tq.c @@ -679,11 +679,6 @@ int32_t tqExpandTask(STQ* pTq, SStreamTask* pTask) { ASSERT(pTask->exec.executor); } - pTask->pState = streamStateOpen(pTq->pStreamMeta->path, pTask); - if (pTask->pState == NULL) { - return -1; - } - // sink /*pTask->ahandle = pTq->pVnode;*/ if (pTask->outputType == TASK_OUTPUT__SMA) { -- GitLab