diff --git a/source/dnode/vnode/src/tq/tqScan.c b/source/dnode/vnode/src/tq/tqScan.c index faf1954667..9a1e188045 100644 --- a/source/dnode/vnode/src/tq/tqScan.c +++ b/source/dnode/vnode/src/tq/tqScan.c @@ -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; diff --git a/source/libs/parser/src/parInsertUtil.c b/source/libs/parser/src/parInsertUtil.c index a77964bb4f..f3ca87e9bc 100644 --- a/source/libs/parser/src/parInsertUtil.c +++ b/source/libs/parser/src/parInsertUtil.c @@ -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; }