enh:[TD-31063] Handling return value of serialize/deserialize.

This commit is contained in:
sima 2024-07-23 09:23:31 +08:00
parent de0fa610f8
commit 0473225362
1 changed files with 4 additions and 1 deletions

View File

@ -6350,7 +6350,10 @@ int32_t blockDistFunction(SqlFunctionCtx* pCtx) {
STableBlockDistInfo* pDistInfo = GET_ROWCELL_INTERBUF(pResInfo);
STableBlockDistInfo p1 = {0};
(void)tDeserializeBlockDistInfo(varDataVal(pInputCol->pData), varDataLen(pInputCol->pData), &p1);
if (tDeserializeBlockDistInfo(varDataVal(pInputCol->pData), varDataLen(pInputCol->pData), &p1) < 0) {
qError("failed to deserialize block dist info");
return TSDB_CODE_FAILED;
}
pDistInfo->numOfBlocks += p1.numOfBlocks;
pDistInfo->numOfTables += p1.numOfTables;