xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

fix:[TD-30365] ci case error & drop topic error if vnode is splitted

This commit is contained in:
wangmm0220 2024-06-06 17:26:20 +08:00
parent 461b4add4c
commit 0e337d3418
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
source/dnode/vnode/src/tq/tq.c
View File

@ -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, tqInfo("vgId:%d switch consumer from Id:0x%" PRIx64 " to Id:0x%" PRIx64, req.vgId, pHandle->consumerId,
req.newConsumerId); req.newConsumerId);
tqUnregisterPushHandle(pTq, pHandle); tqUnregisterPushHandle(pTq, pHandle);
taosHashRemove(pTq->pHandle, pHandle->subKey, strlen(pHandle->subKey));
// update handle to avoid req->qmsg changed if spilt vnode is failed // update handle to avoid req->qmsg changed if spilt vnode is failed
STqHandle handle = {0}; STqHandle handle = {0};
ret = tqCreateHandle(pTq, &req, &handle, pHandle->snapshotVer); ret = tqCreateHandle(pTq, &req, &handle, pHandle->snapshotVer);
if (ret < 0) { if (ret < 0) {
tqDestroyTqHandle(&handle); tqDestroyTqHandle(&handle);
taosWUnLockLatch(&pTq->lock);
goto end; goto end;
} }
ret = tqMetaSaveHandle(pTq, req.subKey, &handle); ret = tqMetaSaveHandle(pTq, req.subKey, &handle);