opti:change push mgr to consume msg for subscribe

41bec856 · wmmhello · 1c63408b · 41bec856
显示空白变更内容
内联并排

Showing with 1 addition and 1 deletion

source/dnode/vnode/src/tq/tq.c source/dnode/vnode/src/tq/tq.c +1 -1

未找到文件。
--- a/source/dnode/vnode/src/tq/tq.c
+++ b/source/dnode/vnode/src/tq/tq.c
@@ -158,8 +158,8 @@ void tqClose(STQ* pTq) {
  taosMemoryFree(pTq->path);
  tqMetaClose(pTq);
  streamMetaClose(pTq->pStreamMeta);
-  taosMemoryFree(pTq);
  taosArrayDestroy(pTq->pPushArray);
+  taosMemoryFree(pTq);
 }

 void tqNotifyClose(STQ* pTq) {