diff --git a/benchmarks/src/bin/tpch.rs b/benchmarks/src/bin/tpch.rs index df64537bd008..44b150f16f63 100644 --- a/benchmarks/src/bin/tpch.rs +++ b/benchmarks/src/bin/tpch.rs @@ -290,14 +290,14 @@ async fn execute_query( debug: bool, ) -> Result> { let plan = ctx.sql(sql).await?; - let plan = plan.to_logical_plan()?; + let plan = plan.to_unoptimized_plan(); if debug { println!("=== Logical plan ===\n{:?}\n", plan); } + let plan = ctx.optimize(&plan)?; if debug { - let plan = ctx.optimize(&plan)?; println!("=== Optimized logical plan ===\n{:?}\n", plan); } let physical_plan = ctx.create_physical_plan(&plan).await?;