public void init ( Props sysProps , Props jobProps , final Logger logger ) { shouldProxy = sysProps . getBoolean ( HadoopSecurityManager . ENABLE_PROXYING , false ) ; jobProps . put ( HadoopSecurityManager . ENABLE_PROXYING , Boolean . toString ( shouldProxy ) ) ; obtainTokens = sysProps . getBoolean ( HadoopSecurityManager . OBTAIN_BINARY_TOKEN , false ) ; if ( shouldProxy ) { logger . info ( "Initiating hadoop security manager." ) ; try { hadoopSecurityManager = HadoopJobUtils . loadHadoopSecurityManager ( sysProps , logger ) ; } catch ( RuntimeException e ) { e . printStackTrace ( ) ; throw new RuntimeException ( "Failed to get hadoop security manager!" + e . getCause ( ) ) ; } } }
Initialize the Hadoop Proxy Object