diff --git a/datafusion/execution/src/memory_pool/mod.rs b/datafusion/execution/src/memory_pool/mod.rs index 30ad658d0d390..737c21dc735fa 100644 --- a/datafusion/execution/src/memory_pool/mod.rs +++ b/datafusion/execution/src/memory_pool/mod.rs @@ -429,7 +429,9 @@ impl MemoryReservation { let size = self.size.load(atomic::Ordering::Relaxed); match capacity.cmp(&size) { Ordering::Greater => self.try_grow(capacity - size)?, - Ordering::Less => self.shrink(size - capacity), + Ordering::Less => { + self.try_shrink(size - capacity)?; + } _ => {} }; Ok(())