import org.apache.hadoop.yarn.client.RMProxy; //导入依赖的package包/类
private TFApplicationRpcClient(String serverAddress, int serverPort) throws IOException {
  InetSocketAddress address = new InetSocketAddress(serverAddress, serverPort);
  Configuration conf = new Configuration();
  RetryPolicy retryPolicy = RMProxy.createRetryPolicy(conf, false);
  TensorFlowCluster proxy = RMProxy.createRMProxy(conf, TensorFlowCluster.class, address);
  this.tensorflow = (TensorFlowCluster) RetryProxy.create(
      TensorFlowCluster.class, proxy, retryPolicy);
}
 

import org.apache.hadoop.yarn.client.RMProxy; //导入依赖的package包/类
@Override
protected ResourceTracker getRMClient() throws IOException {
  RetryPolicy retryPolicy = RMProxy.createRetryPolicy(conf);
  resourceTracker =
      (ResourceTracker) RetryProxy.create(ResourceTracker.class,
        new MyResourceTracker6(rmStartIntervalMS, rmNeverStart),
        retryPolicy);
  return resourceTracker;
}
 

import org.apache.hadoop.yarn.client.RMProxy; //导入依赖的package包/类
@Override
protected ResourceTracker getRMClient() throws IOException {
  RetryPolicy retryPolicy = RMProxy.createRetryPolicy(conf);
  resourceTracker =
      (ResourceTracker) RetryProxy.create(ResourceTracker.class,
        new MyResourceTracker6(this.context, rmStartIntervalMS,
          rmNeverStart), retryPolicy);
  return resourceTracker;
}