code: private static ClusterManagerService.Client getCMSClient(CoronaConf conf)
      throws TTransportException {
      InetSocketAddress address = NetUtils.createSocketAddr(conf
          .getClusterManagerAddress());
      TFramedTransport transport = new TFramedTransport(
        new TSocket(address.getHostName(), address.getPort()));
      ClusterManagerService.Client client = new ClusterManagerService.Client(
          new TBinaryProtocol(transport));
      transport.open();
      return client;
    }
docs: Get the thrift client to communicate with the cluster manager
  @return a thrift client initialized to talk to the cluster manager
  @param conf The configuration.
  @throws TTransportException