diff --git a/utils/rowgroup/rowstorage.cpp b/utils/rowgroup/rowstorage.cpp index 438c9ef9e..9d90c2bad 100644 --- a/utils/rowgroup/rowstorage.cpp +++ b/utils/rowgroup/rowstorage.cpp @@ -684,7 +684,13 @@ class RowGroupStorage logging::ERR_AGGREGATION_TOO_BIG); } - fLRU->add(rgid); + if (fMM->getFree() < memSz * 2) + { + saveRG(rgid); + fRGDatas[rgid].reset(); + } + else + fLRU->add(rgid); } else {