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

fix:[TS-5776]add raw type from consumer

This commit is contained in:
wangmm0220 2025-02-14 16:12:00 +08:00
parent d67de02a31
commit f16f21897e
2 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
source/dnode/vnode/src/tq/tqScan.c
View File

@ -400,10 +400,7 @@ static void preProcessSubmitMsg(STqHandle* pHandle, const SMqPollReq* pRequest,
*rawList = NULL;
return;
}
if (pSubmitTbData->pCreateTbReq == NULL){
continue;
}
int64_t createTime = 0;
int64_t uid = pSubmitTbData->uid;
if (taosHashGet(pRequest->uidHash, &uid, LONG_BYTES) != NULL) {
tqDebug("poll rawdata split,uid:%" PRId64 " is already exists", uid);
@ -415,6 +412,11 @@ static void preProcessSubmitMsg(STqHandle* pHandle, const SMqPollReq* pRequest,
}
}
if (pSubmitTbData->pCreateTbReq == NULL){
continue;
}
int64_t createTime = 0;
int64_t *cTime = (int64_t*)taosHashGet(pHandle->tableCreateTimeHash, &uid, LONG_BYTES);
if (cTime != NULL){
createTime = *cTime;

2
source/libs/parser/src/parInsertUtil.c
View File

@ -1100,7 +1100,7 @@ int rawBlockBindRawData(SHashObj* pVgroupHash, SArray* pVgroupList, STableMeta*
return terrno;
}
qDebug("add raw data to vgId:%d, len:%d", pTableMeta->vgId, *(int32_t*)data);
uTrace("add raw data to vgId:%d, len:%d", pTableMeta->vgId, *(int32_t*)data);
return 0;
}