提交 0d1b2e4b 编写于 作者: H Haojun Liao

fix(tmq): use before remove hash item.

上级 b31b7c3f
...@@ -383,11 +383,11 @@ int32_t tqRemovePushEntry(STQ* pTq, const char* pKey, int32_t keyLen, uint64_t c ...@@ -383,11 +383,11 @@ int32_t tqRemovePushEntry(STQ* pTq, const char* pKey, int32_t keyLen, uint64_t c
tqDebug("tmq poll: consumer:0x%" PRIx64 ", subkey %s vgId:%d remove from push mgr, remains:%d", consumerId, tqDebug("tmq poll: consumer:0x%" PRIx64 ", subkey %s vgId:%d remove from push mgr, remains:%d", consumerId,
(*pEntry)->subKey, vgId, taosHashGetSize(pTq->pPushMgr) - 1); (*pEntry)->subKey, vgId, taosHashGetSize(pTq->pPushMgr) - 1);
taosHashRemove(pTq->pPushMgr, pKey, keyLen);
if (rspConsumer) { // rsp the old consumer with empty block. if (rspConsumer) { // rsp the old consumer with empty block.
tqPushDataRsp(pTq, *pEntry); tqPushDataRsp(pTq, *pEntry);
} }
taosHashRemove(pTq->pPushMgr, pKey, keyLen);
} }
return 0; return 0;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册