Skip to content

Commit 6a44ab9

Browse files
Fix hanging problem due to lock
1 parent 897b01c commit 6a44ab9

File tree

1 file changed

+2
-7
lines changed
  • datafusion/execution/src/memory_pool

1 file changed

+2
-7
lines changed

datafusion/execution/src/memory_pool/pool.rs

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -294,17 +294,13 @@ impl MemoryPool for FairSpillPool {
294294

295295
impl Display for FairSpillPool {
296296
fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result {
297-
let state = self.state.lock();
298297
write!(
299298
f,
300299
"{}",
301300
format_args!(
302-
"{}(pool_size: {}, num_spill: {}, spillable: {}, unspillable: {})",
301+
"{}(pool_size: {})",
303302
&self.name(),
304303
human_readable_size(self.pool_size),
305-
state.num_spill,
306-
state.spillable,
307-
state.unspillable
308304
)
309305
)
310306
}
@@ -432,11 +428,10 @@ impl<I: MemoryPool> Display for TrackConsumersPool<I> {
432428
f,
433429
"{}",
434430
format_args!(
435-
"{}(inner_pool: {}, num_of_top_consumers: {}, num_of_total_consumers: {})",
431+
"{}(inner_pool: {}, num_of_top_consumers: {})",
436432
&self.name(),
437433
&self.inner,
438434
&self.top,
439-
&self.tracked_consumers.lock().iter().count()
440435
)
441436
)
442437
}

0 commit comments

Comments
 (0)