database/mariadb-columnstore-engine
1
0
Fork 0
mirror of https://github.com/mariadb-corporation/mariadb-columnstore-engine.git synced 2025-07-30 19:23:07 +03:00
Code Activity

MCOL-4685 Fix bug after rebase and add comments.

Browse Source
This commit is contained in:
Denis Khalikov
2021-06-07 12:55:18 +03:00
parent 606194e6e4
commit caa02a383a
1 changed files with 9 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
writeengine/bulk/we_colbufcompressed.cpp
View File

@ -590,10 +590,15 @@ int ColumnBufferCompressed::saveCompressionHeaders( )
fColInfo->column.compressionType); fColInfo->column.compressionType);
fCompressor->setBlockCount(hdrBuf, fCompressor->setBlockCount(hdrBuf,
(fColInfo->getFileSize() / BYTE_PER_BLOCK) ); (fColInfo->getFileSize() / BYTE_PER_BLOCK) );
// If lbid written in the header is not 0 - we are running for the next extent for column // If lbid written in the header is not 0 and not equal to `lastupdatedlbid` - we are running
// segment file. // for the next extent for column segment file.
if (lbid) const auto lastUpdatedLbid = fColInfo->getLastUpdatedLBID();
fCompressor->setLBIDByIndex(hdrBuf, fColInfo->getLastUpdatedLBID(), 1); if (lbid && lastUpdatedLbid != lbid)
{
// Write back lbid, after header initialization.
fCompressor->setLBIDByIndex(hdrBuf, lbid, 0);
fCompressor->setLBIDByIndex(hdrBuf, lastUpdatedLbid, 1);
}
else else
fCompressor->setLBIDByIndex(hdrBuf, fColInfo->getLastUpdatedLBID(), 0); fCompressor->setLBIDByIndex(hdrBuf, fColInfo->getLastUpdatedLBID(), 0);