database/mariadb-columnstore-engine
1
0
Fork 0
mirror of https://github.com/mariadb-corporation/mariadb-columnstore-engine.git synced 2025-08-05 16:15:50 +03:00
Code Activity

[MCOL-5213] Fix a rare IO error

Browse Source
This commit is contained in:
Alexey Antipovsky
2022-09-04 23:44:19 +00:00
parent 1bef5da109
commit 440101dfff
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
utils/rowgroup/rowstorage.cpp
View File

@@ -1556,9 +1556,10 @@ bool RowAggStorage::getTargetRow(const Row& row, uint64_t hash, Row& rowOut)
!fEnabledDiskAggregation, fCompressor.get())); !fEnabledDiskAggregation, fCompressor.get()));
if (fExtKeys) if (fExtKeys)
{ {
fKeysStorage = new RowGroupStorage(fTmpDir, fKeysRowGroup, fMaxRows, fMM->getResourceManaged(), fRealKeysStorage.reset(new RowGroupStorage(fTmpDir, fKeysRowGroup, fMaxRows, fMM->getResourceManaged(),
fMM->getSessionLimit(), !fEnabledDiskAggregation, fMM->getSessionLimit(), !fEnabledDiskAggregation,
!fEnabledDiskAggregation, fCompressor.get()); !fEnabledDiskAggregation, fCompressor.get()));
fKeysStorage = fRealKeysStorage.get();
} }
else else
{ {