diff --git a/source/libs/executor/src/dataDispatcher.c b/source/libs/executor/src/dataDispatcher.c index 64b54ab13571f85770a5250acb7c6ae1810cc805..0e1fa5267d634681ff572224a067c0d8ade5f128 100644 --- a/source/libs/executor/src/dataDispatcher.c +++ b/source/libs/executor/src/dataDispatcher.c @@ -140,7 +140,7 @@ static bool allocBuf(SDataDispatchHandle* pDispatcher, const SInputData* pInput, // NOTE: there are four bytes of an integer more than the required buffer space. // struct size + data payload + length for each column + bitmap length pBuf->allocSize = sizeof(SRetrieveTableRsp) + blockDataGetSerialMetaSize(pInput->pData) + - __ceill(blockDataGetSerialRowSize(pInput->pData) * pInput->pData->info.rows); + ceil(blockDataGetSerialRowSize(pInput->pData) * pInput->pData->info.rows); pBuf->pData = malloc(pBuf->allocSize); if (pBuf->pData == NULL) {