void function ( String arg0 , String arg1 ) { if ( ! shuffleSecretMap . contains ( arg0 ) ) { shuffleSecretMap . put ( arg0 , arg1 ) ; logger . info ( "srini_string" , arg0 ) ; } else { logger . debug ( "srini_string" , arg0 ) ; } }
register an application with its secret . executors need to first authenticate themselves with the same secret before fetching shuffle files written by other executors in this application . concode_field_sep ConcurrentHashMap<String,String> shuffleSecretMap concode_elem_sep Logger logger concode_elem_sep String SPARK_SASL_USER concode_field_sep String getSecretKey concode_elem_sep void unregisterApp concode_elem_sep String getSaslUser