fix(stream): memory leak

d4c73941 · Liu Jicong · dd5b2b73 · d4c73941
显示空白变更内容
内联并排

Showing with 1 addition and 2 deletion

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

未找到文件。
--- a/source/dnode/vnode/src/tq/tqPush.c
+++ b/source/dnode/vnode/src/tq/tqPush.c
@@ -308,9 +308,8 @@ int tqPushMsg(STQ* pTq, void* msg, int32_t msgLen, tmsg_t msgType, int64_t ver)
  }
  if (vnodeIsRoleLeader(pTq->pVnode)) {
-    if (msgType == TDMT_VND_SUBMIT) {
    if (taosHashGetSize(pTq->pStreamMeta->pTasks) == 0) return 0;
+    if (msgType == TDMT_VND_SUBMIT) {
      void* data = taosMemoryMalloc(msgLen);
      if (data == NULL) {
        terrno = TSDB_CODE_OUT_OF_MEMORY;