fix:tq memory leak

519e2f1c · 54liuyao · dace3393 · 519e2f1c
隐藏空白更改
内联并排

Showing with 2 addition and 0 deletion

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

未找到文件。
--- a/source/dnode/vnode/src/tq/tq.c
+++ b/source/dnode/vnode/src/tq/tq.c
@@ -1559,6 +1559,8 @@ int32_t vnodeEnqueueStreamMsg(SVnode* pVnode, SRpcMsg* pMsg) {
    rpcFreeCont(pMsg->pCont);
    taosFreeQitem(pMsg);
    return 0;
+  } else {
+    tDeleteStreamDispatchReq(&req);
  }

  code = TSDB_CODE_STREAM_TASK_NOT_EXIST;