File tree Expand file tree Collapse file tree 1 file changed +2
-1
lines changed
plugins/engine-datafusion/jni/src Expand file tree Collapse file tree 1 file changed +2
-1
lines changed Original file line number Diff line number Diff line change @@ -88,7 +88,7 @@ pub async fn execute_query_with_cross_rt_stream(
8888 config. options_mut ( ) . execution . batch_size = 1024 ;
8989
9090 let state = datafusion:: execution:: SessionStateBuilder :: new ( )
91- . with_config ( config)
91+ . with_config ( config. clone ( ) )
9292 . with_runtime_env ( Arc :: from ( runtime_env) )
9393 . with_default_features ( )
9494 //.with_physical_optimizer_rule(Arc::new(ProjectRowIdOptimizer)) // TODO : uncomment this after fix
@@ -102,6 +102,7 @@ pub async fn execute_query_with_cross_rt_stream(
102102 let listing_options = ListingOptions :: new ( Arc :: new ( file_format) )
103103 . with_file_extension ( ".parquet" )
104104 . with_files_metadata ( files_meta)
105+ . with_session_config_options ( & config)
105106 . with_table_partition_cols ( vec ! [ ( "row_base" . to_string( ) , DataType :: Int64 ) ] ) ;
106107
107108 let resolved_schema = match listing_options
You can’t perform that action at this time.
0 commit comments