From 141a516d32ff26f45461a4eaf0ca7cabd76fea74 Mon Sep 17 00:00:00 2001 From: Adam Gutglick Date: Mon, 27 Jul 2026 16:24:21 +0100 Subject: [PATCH] fix: Fix datafusion benchmark, attaching table ref to table URL Signed-off-by: Adam Gutglick --- benchmarks/datafusion-bench/src/main.rs | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/benchmarks/datafusion-bench/src/main.rs b/benchmarks/datafusion-bench/src/main.rs index 8c67896c64b..094ca59461a 100644 --- a/benchmarks/datafusion-bench/src/main.rs +++ b/benchmarks/datafusion-bench/src/main.rs @@ -21,6 +21,7 @@ use datafusion_bench::metrics::MetricsSetExt; use datafusion_bench::tracer::get_labelset_from_global; use datafusion_bench::tracer::get_static_tracer; use datafusion_bench::tracer::set_labels; +use datafusion_common::TableReference; use datafusion_physical_plan::ExecutionPlan; use datafusion_physical_plan::collect; use parking_lot::Mutex; @@ -266,7 +267,9 @@ async fn register_benchmark_tables( for table in benchmark.table_specs().iter() { let pattern = benchmark.pattern(table.name, format); - let table_url = ListingTableUrl::try_new(benchmark_base.clone(), pattern)?; + let table_ref = TableReference::bare(table.name); + let table_url = ListingTableUrl::try_new(benchmark_base.clone(), pattern)? + .with_table_ref(table_ref.clone()); let listing_options = ListingOptions::new(Arc::clone(&file_format)) .with_session_config_options(session.state().config()); @@ -287,7 +290,7 @@ async fn register_benchmark_tables( ), ); - session.register_table(table.name, listing_table)?; + session.register_table(table_ref, listing_table)?; } Ok(())