fix(query): update last_row callback function.

This commit is contained in:
Haojun Liao 2022-10-18 19:13:42 +08:00
parent e4940e82c5
commit d7e01b30c7
1 changed files with 1 additions and 1 deletions

View File

@ -54,7 +54,7 @@ static void saveOneRow(SArray* pRow, SSDataBlock* pBlock, SCacheRowsReader* pRea
if (IS_VAR_DATA_TYPE(pColVal->colVal.type)) {
varDataSetLen(p->buf, pColVal->colVal.value.nData);
memcpy(varDataVal(p->buf), pColVal->colVal.value.pData, pColVal->colVal.value.nData);
p->bytes = pColVal->colVal.value.nData;
p->bytes = pColVal->colVal.value.nData + VARSTR_HEADER_SIZE;
} else {
memcpy(p->buf, &pColVal->colVal.value, pReader->pSchema->columns[slotId].bytes);
p->bytes = pReader->pSchema->columns[slotId].bytes;