fix(query): fix error

This commit is contained in:
Ganlin Zhao 2022-05-18 16:53:17 +08:00
parent e948d5a248
commit dbe43425f1
1 changed files with 1 additions and 3 deletions

View File

@ -322,10 +322,8 @@ int32_t colDataAssign(SColumnInfoData* pColumnInfoData, const SColumnInfoData* p
} }
pColumnInfoData->pData = tmp; pColumnInfoData->pData = tmp;
if (pColumnInfoData->info.type != TSDB_DATA_TYPE_NULL) {
memcpy(pColumnInfoData->pData, pSource->pData, pSource->info.bytes * numOfRows); memcpy(pColumnInfoData->pData, pSource->pData, pSource->info.bytes * numOfRows);
} }
}
pColumnInfoData->hasNull = pSource->hasNull; pColumnInfoData->hasNull = pSource->hasNull;
pColumnInfoData->info = pSource->info; pColumnInfoData->info = pSource->info;