From 0e337d34186717aae935cd6278588710659e9794 Mon Sep 17 00:00:00 2001
From: wangmm0220 <wangmm0220@gmail.com>
Date: Thu, 6 Jun 2024 17:26:20 +0800
Subject: [PATCH] fix:[TD-30365] ci case error & drop topic error if vnode is
 splitted

---
 source/dnode/vnode/src/tq/tq.c | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/source/dnode/vnode/src/tq/tq.c b/source/dnode/vnode/src/tq/tq.c
index 925f8feb05..58085e2cc2 100644
--- a/source/dnode/vnode/src/tq/tq.c
+++ b/source/dnode/vnode/src/tq/tq.c
@@ -685,13 +685,13 @@ int32_t tqProcessSubscribeReq(STQ* pTq, int64_t sversion, char* msg, int32_t msg
         tqInfo("vgId:%d switch consumer from Id:0x%" PRIx64 " to Id:0x%" PRIx64, req.vgId, pHandle->consumerId,
                req.newConsumerId);
         tqUnregisterPushHandle(pTq, pHandle);
-        taosHashRemove(pTq->pHandle, pHandle->subKey, strlen(pHandle->subKey));
 
         // update handle to avoid req->qmsg changed if spilt vnode is failed
         STqHandle handle = {0};
         ret = tqCreateHandle(pTq, &req, &handle, pHandle->snapshotVer);
         if (ret < 0) {
           tqDestroyTqHandle(&handle);
+          taosWUnLockLatch(&pTq->lock);
           goto end;
         }
         ret = tqMetaSaveHandle(pTq, req.subKey, &handle);