other: revert to 3.0

23098a08 · Cary Xu · e75ed9f0 · 23098a08
显示空白变更内容
内联并排

Showing with 0 addition and 5 deletion

source/dnode/vnode/src/tq/tq.c source/dnode/vnode/src/tq/tq.c +0 -5

未找到文件。
--- 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) {