@@ -910,20 +910,6 @@ fn build_rolegroup_config_map(
910910 }
911911 }
912912
913- // Add client protocol properties (especially spooling properties)
914- if let Some ( spooling_config) = resolved_spooling_config {
915- let spooling_props_with_options: BTreeMap < String , Option < String > > = spooling_config
916- . spooling_manager_properties
917- . iter ( )
918- . map ( |( k, v) | ( k. clone ( ) , Some ( v. clone ( ) ) ) )
919- . collect ( ) ;
920- cm_conf_data. insert (
921- SPOOLING_MANAGER_PROPERTIES . to_string ( ) ,
922- to_java_properties_string ( spooling_props_with_options. iter ( ) )
923- . with_context ( |_| FailedToWriteJavaPropertiesSnafu ) ?,
924- ) ;
925- }
926-
927913 let jvm_sec_props: BTreeMap < String , Option < String > > = config
928914 . get ( & PropertyNameKind :: File ( JVM_SECURITY_PROPERTIES . to_string ( ) ) )
929915 . cloned ( )
@@ -1925,7 +1911,6 @@ mod tests {
19251911 ) ] ) ,
19261912 volume_mounts : vec ! [ ] ,
19271913 volumes : vec ! [ ] ,
1928- load_env_from_files : BTreeMap :: new ( ) ,
19291914 init_container_extra_start_commands : vec ! [ ] ,
19301915 } ) ;
19311916
@@ -1937,6 +1922,9 @@ mod tests {
19371922 assert ! ( config. contains( "protocol.spooling.shared-secret-key=test" ) ) ;
19381923
19391924 let config = cm. get ( "spooling-manager.properties" ) . unwrap ( ) ;
1925+ println ! ( "------" ) ;
1926+ println ! ( "{}" , config) ;
1927+ println ! ( "------" ) ;
19401928 assert ! ( config. contains( "fs.location=s3a\\ ://bucket/cluster/spooling" ) ) ;
19411929 assert ! ( config. contains( "spooling-manager.name=filesystem" ) ) ;
19421930 }
0 commit comments