WIP recursive arbitration

tanjialiang · Nov 12, 2024 · 94db522 · 94db522
1 parent afa6572
commit 94db522
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/velox/common/memory/MemoryPool.cpp b/velox/common/memory/MemoryPool.cpp
@@ -896,6 +896,9 @@ bool MemoryPoolImpl::maybeIncrementReservation(uint64_t size) {
             !underMemoryArbitration())) {
       return false;
     }
+    if (underMemoryArbitration()) {
+      ::abort();
+    }
   }
   incrementReservationLocked(size);
   return true;

diff --git a/velox/exec/fuzzer/MemoryArbitrationFuzzer.cpp b/velox/exec/fuzzer/MemoryArbitrationFuzzer.cpp
@@ -742,7 +742,7 @@ void MemoryArbitrationFuzzer::verify() {
   }
 
   std::this_thread::sleep_for(
-      std::chrono::seconds(FLAGS_iteration_duration_sec));
+      std::chrono::seconds(7200));
   stop = true;
 
   for (auto& queryThread : queryThreads) {