Merge pull request #14165 from taosdata/feature/TD-16728
fix(stream): valgrind memory error
This commit is contained in:
commit
19fab3fe8f
|
@ -2238,7 +2238,8 @@ static void clearUpdateDataBlock(SSDataBlock* pBlock) {
|
||||||
}
|
}
|
||||||
|
|
||||||
void copyUpdateDataBlock(SSDataBlock* pDest, SSDataBlock* pSource, int32_t tsColIndex) {
|
void copyUpdateDataBlock(SSDataBlock* pDest, SSDataBlock* pSource, int32_t tsColIndex) {
|
||||||
ASSERT(pDest->info.capacity >= pSource->info.rows);
|
// ASSERT(pDest->info.capacity >= pSource->info.rows);
|
||||||
|
blockDataEnsureCapacity(pDest, pSource->info.rows);
|
||||||
clearUpdateDataBlock(pDest);
|
clearUpdateDataBlock(pDest);
|
||||||
SColumnInfoData* pDestCol = taosArrayGet(pDest->pDataBlock, 0);
|
SColumnInfoData* pDestCol = taosArrayGet(pDest->pDataBlock, 0);
|
||||||
SColumnInfoData* pSourceCol = taosArrayGet(pSource->pDataBlock, tsColIndex);
|
SColumnInfoData* pSourceCol = taosArrayGet(pSource->pDataBlock, tsColIndex);
|
||||||
|
|
Loading…
Reference in New Issue