Skip to content

Commit

Permalink
Deadlock removed
Browse files Browse the repository at this point in the history
  • Loading branch information
m09526 committed May 3, 2024
1 parent 3d7f3b3 commit b1565ea
Showing 1 changed file with 5 additions and 2 deletions.
7 changes: 5 additions & 2 deletions rust/compaction/src/datafusion.rs
Original file line number Diff line number Diff line change
Expand Up @@ -141,15 +141,18 @@ pub async fn compact(
let binding = sketch_func.inner();
let inner_function: Option<&SketchUDF> = binding.as_any().downcast_ref();
if let Some(func) = inner_function {
let first_sketch = &func.get_sketch()[0];
info!(
{
// Limit scope of MutexGuard
let first_sketch = &func.get_sketch()[0];
info!(
"Made {} calls to sketch UDF and processed {} total rows. Quantile sketch column 0 retained {} out of {} values (K value = {}).",
func.get_invoke_count().to_formatted_string(&Locale::en),
func.get_row_count().to_formatted_string(&Locale::en),
first_sketch.get_num_retained(),
first_sketch.get_n(),
first_sketch.get_k()
);
}

rows_written = func.get_row_count();

Expand Down

0 comments on commit b1565ea

Please sign in to comment.