@@ -100,7 +100,7 @@ use async_trait::async_trait;
100100use datafusion_physical_plan:: async_func:: { AsyncFuncExec , AsyncMapper } ;
101101use futures:: { StreamExt , TryStreamExt } ;
102102use itertools:: { multiunzip, Itertools } ;
103- use log:: { debug, trace } ;
103+ use log:: debug;
104104use tokio:: sync:: Mutex ;
105105
106106/// Physical query planner that converts a `LogicalPlan` to an
@@ -2048,7 +2048,7 @@ impl DefaultPhysicalPlanner {
20482048 "Input physical plan:\n {}\n " ,
20492049 displayable( plan. as_ref( ) ) . indent( false )
20502050 ) ;
2051- trace ! (
2051+ debug ! (
20522052 "Detailed input physical plan:\n {}" ,
20532053 displayable( plan. as_ref( ) ) . indent( true )
20542054 ) ;
@@ -2070,7 +2070,7 @@ impl DefaultPhysicalPlanner {
20702070 OptimizationInvariantChecker :: new ( optimizer)
20712071 . check ( & new_plan, before_schema) ?;
20722072
2073- trace ! (
2073+ debug ! (
20742074 "Optimized physical plan by {}:\n {}\n " ,
20752075 optimizer. name( ) ,
20762076 displayable( new_plan. as_ref( ) ) . indent( false )
@@ -2086,7 +2086,7 @@ impl DefaultPhysicalPlanner {
20862086 "Optimized physical plan:\n {}\n " ,
20872087 displayable( new_plan. as_ref( ) ) . indent( false )
20882088 ) ;
2089- trace ! ( "Detailed optimized physical plan:\n {new_plan:?}" ) ;
2089+ debug ! ( "Detailed optimized physical plan:\n {new_plan:?}" ) ;
20902090 Ok ( new_plan)
20912091 }
20922092
0 commit comments