fix(query): set correct length value.

This commit is contained in:
Haojun Liao 2022-08-30 10:38:32 +08:00
parent 45616c6548
commit d338e4dc60
1 changed files with 1 additions and 2 deletions

View File

@ -3627,8 +3627,7 @@ static int32_t doUpdateTupleData(SSerializeDataHandle* pHandle, const void* pBuf
} }
static int32_t updateTupleData(SqlFunctionCtx* pCtx, int32_t rowIndex, const SSDataBlock* pSrcBlock, STuplePos* pPos) { static int32_t updateTupleData(SqlFunctionCtx* pCtx, int32_t rowIndex, const SSDataBlock* pSrcBlock, STuplePos* pPos) {
int32_t rowLen = 0; int32_t completeRowSize = pCtx->subsidiaries.rowLen + pCtx->subsidiaries.num * sizeof(bool);
int32_t completeRowSize = rowLen + pCtx->subsidiaries.num * sizeof(bool);
char* buf = serializeTupleData(pSrcBlock, rowIndex, &pCtx->subsidiaries, pCtx->subsidiaries.buf); char* buf = serializeTupleData(pSrcBlock, rowIndex, &pCtx->subsidiaries, pCtx->subsidiaries.buf);
doUpdateTupleData(&pCtx->saveHandle, buf, completeRowSize, pPos); doUpdateTupleData(&pCtx->saveHandle, buf, completeRowSize, pPos);
return TSDB_CODE_SUCCESS; return TSDB_CODE_SUCCESS;