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

feat:[TD-33798]modify metadata logic for tmq

This commit is contained in:
wangmm0220 2025-02-24 16:18:27 +08:00
parent b5e673f727
commit e87541efaa
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
source/dnode/vnode/src/tq/tqUtil.c
View File

@ -389,7 +389,7 @@ static int32_t extractDataAndRspForDbStbSubscribe(STQ* pTq, STqHandle* pHandle,
code = buildBatchMeta(&btMetaRsp, pHead->msgType, pHead->bodyLen, pHead->body); code = buildBatchMeta(&btMetaRsp, pHead->msgType, pHead->bodyLen, pHead->body);
fetchVer++; fetchVer++;
if (code != 0){ if (code != 0){
continue; goto END;
} }
totalMetaRows++; totalMetaRows++;
if ((taosArrayGetSize(btMetaRsp.batchMetaReq) >= tmqRowSize) || (taosGetTimestampMs() - st > pRequest->timeout)) { if ((taosArrayGetSize(btMetaRsp.batchMetaReq) >= tmqRowSize) || (taosGetTimestampMs() - st > pRequest->timeout)) {
@ -423,7 +423,7 @@ static int32_t extractDataAndRspForDbStbSubscribe(STQ* pTq, STqHandle* pHandle,
taosxRsp.createTableReq = NULL; taosxRsp.createTableReq = NULL;
fetchVer++; fetchVer++;
if (code != 0){ if (code != 0){
continue; goto END;
} }
totalMetaRows++; totalMetaRows++;
if ((taosArrayGetSize(btMetaRsp.batchMetaReq) >= tmqRowSize) || if ((taosArrayGetSize(btMetaRsp.batchMetaReq) >= tmqRowSize) ||