void initializeClientUnprotected ( String host , int port , String sessionId ) throws IOException { if ( client != null ) { return ; } LOG . info ( "Creating JT client to " + host + ":" + port ) ; long connectTimeout = RemoteJTProxy . getRemotJTTimeout ( conf ) ; int rpcTimeout = RemoteJTProxy . getRemoteJTRPCTimeout ( conf ) ; remoteJTAddr = new InetSocketAddress ( host , port ) ; client = RPC . waitForProtocolProxy ( JobSubmissionProtocol . class , JobSubmissionProtocol . versionID , remoteJTAddr , conf , connectTimeout , rpcTimeout ) . getProxy ( ) ; remoteJTStatus = RemoteJTStatus . SUCCESS ; remoteJTHost = host ; remoteJTPort = port ; remoteSessionId = sessionId ; if ( remoteJTState != null ) { remoteJTState . setSessionId ( sessionId ) ; } }
Create the RPC client to the remote corona job tracker .