code: 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);
      }
    }
docs: Create the RPC client to the remote corona job tracker.
  @param host The host running the remote corona job tracker.
  @param port The port of the remote corona job tracker.
  @param sessionId The session for the remote corona job tracker.
  @throws IOException