diff --git a/source/common/src/tdatablock.c b/source/common/src/tdatablock.c index eacb7b1188ebbed4bcae001accfc798af68a9cda..519c2b0962a2b2a78d4f4b6907ab34e7fbc0886c 100644 --- a/source/common/src/tdatablock.c +++ b/source/common/src/tdatablock.c @@ -2012,9 +2012,9 @@ char* dumpBlockData(SSDataBlock* pDataBlock, const char* flag, char** pDataBuf) * */ #if 0 -int32_t buildSubmitReqFromDataBlock(SSubmitReq2** pReq, const SSDataBlock* pDataBlock, STSchema* pTSchema, int32_t vgId, +int32_t buildSubmitReqFromDataBlock(SSubmitReq** pReq, const SSDataBlock* pDataBlock, STSchema* pTSchema, int32_t vgId, tb_uid_t suid) { - int32_t bufSize = sizeof(SSubmitReq2); + int32_t bufSize = sizeof(SSubmitReq); int32_t sz = 1; for (int32_t i = 0; i < sz; ++i) { const SDataBlockInfo* pBlkInfo = &pDataBlock->info; diff --git a/source/dnode/vnode/src/sma/smaTimeRange.c b/source/dnode/vnode/src/sma/smaTimeRange.c index cf1e5d5d397df0e5de2c41e15c9dd92adbcfabe0..f82c6f6e1f6cb257c4f11836711177ef1118b13f 100644 --- a/source/dnode/vnode/src/sma/smaTimeRange.c +++ b/source/dnode/vnode/src/sma/smaTimeRange.c @@ -224,7 +224,7 @@ static int32_t tdProcessTSmaInsertImpl(SSma *pSma, int64_t indexUid, const char SRpcMsg submitReqMsg = { .msgType = TDMT_VND_SUBMIT, .pCont = pSubmitReq, - .contLen = ntohl(contLen), + .contLen = ntohl(pSubmitReq->length), }; if (tmsgPutToQueue(&pSma->pVnode->msgCb, WRITE_QUEUE, &submitReqMsg) < 0) {