feat(sorting): fixed data flush with in-memory reset.

drrtuy · drrtuy · commit d9187e647477 · 2025-06-17T14:22:10.000Z
diff --git a/dbcon/joblist/limitedorderby.cpp b/dbcon/joblist/limitedorderby.cpp
@@ -263,10 +263,14 @@ void LimitedOrderBy::flushCurrentToDisk_(const bool firstFlush)
   // orderedRowsQueue
   queue<RGData> tempQueue;
   fDataQueue.swap(tempQueue);
+
   if (fDistinctMap)
   {
     fDistinctMap->clear();
   }
+  
+  fRm->returnMemory(fMemSize);
+  fMemSize = 0;
 
   flushThread.join();
 }

Original file line number	Diff line number	Diff line change
`@@ -263,10 +263,14 @@ void LimitedOrderBy::flushCurrentToDisk_(const bool firstFlush)`
`263`	`263`	`// orderedRowsQueue`
`264`	`264`	`queue<RGData> tempQueue;`
`265`	`265`	`fDataQueue.swap(tempQueue);`
	`266`	`+`
`266`	`267`	`if (fDistinctMap)`
`267`	`268`	`{`
`268`	`269`	`fDistinctMap->clear();`
`269`	`270`	`}`
	`271`	`+`
	`272`	`+ fRm->returnMemory(fMemSize);`
	`273`	`+ fMemSize = 0;`
`270`	`274`
`271`	`275`	`flushThread.join();`
`272`	`276`	`}`