From 57a2471cc66b6f041dea4aab35c7804e62b602dc Mon Sep 17 00:00:00 2001 From: Haojun Liao Date: Sat, 15 Feb 2025 00:03:33 +0800 Subject: [PATCH] fix(stream): add missing release --- source/dnode/vnode/src/tqCommon/tqCommon.c | 1 + 1 file changed, 1 insertion(+) diff --git a/source/dnode/vnode/src/tqCommon/tqCommon.c b/source/dnode/vnode/src/tqCommon/tqCommon.c index bcf60f5c32..77632d328e 100644 --- a/source/dnode/vnode/src/tqCommon/tqCommon.c +++ b/source/dnode/vnode/src/tqCommon/tqCommon.c @@ -1217,6 +1217,7 @@ int32_t tqStreamTaskProcessTaskResumeReq(void* handle, int64_t sversion, char* m streamMetaReleaseTask(pMeta, pHTask); } + streamMetaReleaseTask(pMeta, pTask); return TSDB_CODE_SUCCESS; }