From 354f33fa887ab327cf6281e36f43d5ecd1805eee Mon Sep 17 00:00:00 2001 From: Yihao Deng Date: Wed, 17 Apr 2024 05:38:45 +0000 Subject: [PATCH] drop stream data --- source/dnode/vnode/src/tqCommon/tqCommon.c | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/source/dnode/vnode/src/tqCommon/tqCommon.c b/source/dnode/vnode/src/tqCommon/tqCommon.c index b304ef3531..7299d172c6 100644 --- a/source/dnode/vnode/src/tqCommon/tqCommon.c +++ b/source/dnode/vnode/src/tqCommon/tqCommon.c @@ -729,9 +729,10 @@ int32_t tqStreamTaskProcessDropReq(SStreamMeta* pMeta, char* msg, int32_t msgLen if (streamMetaCommit(pMeta) < 0) { // persist to disk } - tqStreamRmTaskBackend(pMeta, &id); streamMetaWUnLock(pMeta); + + tqStreamRmTaskBackend(pMeta, &id); return 0; }