chore: log memory reservations

influxdata · Sep 5, 2024 · d5a5f35 · d5a5f35
1 parent c6c7a73
commit d5a5f35
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/datafusion/execution/src/memory_pool/pool.rs b/datafusion/execution/src/memory_pool/pool.rs
@@ -346,6 +346,8 @@ impl<I: MemoryPool> MemoryPool for TrackConsumersPool<I> {
             .and_modify(|bytes| {
                 bytes.fetch_add(additional as u64, Ordering::AcqRel);
             });
+
+        println!("REPORT: {}", self.report_top(5));
     }
 
     fn shrink(&self, reservation: &MemoryReservation, shrink: usize) {
@@ -380,6 +382,8 @@ impl<I: MemoryPool> MemoryPool for TrackConsumersPool<I> {
             .and_modify(|bytes| {
                 bytes.fetch_add(additional as u64, Ordering::AcqRel);
             });
+        println!("REPORT: {}", self.report_top(5));
+
         Ok(())
     }