File tree Expand file tree Collapse file tree 1 file changed +3
-5
lines changed
datafusion/core/tests/memory_limit Expand file tree Collapse file tree 1 file changed +3
-5
lines changed Original file line number Diff line number Diff line change @@ -534,11 +534,9 @@ async fn setup_context(
534534 disk_limit : u64 ,
535535 memory_pool_limit : usize ,
536536) -> Result < SessionContext > {
537- let disk_manager = DiskManager :: try_new ( DiskManagerConfig :: NewOs ) ?;
537+ let mut disk_manager = DiskManager :: try_new ( DiskManagerConfig :: NewOs ) ?;
538538
539- let disk_manager = Arc :: try_unwrap ( disk_manager)
540- . expect ( "DiskManager should be a single instance" )
541- . with_max_temp_directory_size ( disk_limit) ?;
539+ DiskManager :: set_arc_max_temp_directory_size ( & mut disk_manager, disk_limit) ?;
542540
543541 let runtime = RuntimeEnvBuilder :: new ( )
544542 . with_memory_pool ( Arc :: new ( FairSpillPool :: new ( memory_pool_limit) ) )
@@ -547,7 +545,7 @@ async fn setup_context(
547545
548546 let runtime = Arc :: new ( RuntimeEnv {
549547 memory_pool : runtime. memory_pool . clone ( ) ,
550- disk_manager : Arc :: new ( disk_manager ) ,
548+ disk_manager,
551549 cache_manager : runtime. cache_manager . clone ( ) ,
552550 object_store_registry : runtime. object_store_registry . clone ( ) ,
553551 } ) ;
You can’t perform that action at this time.
0 commit comments