Details
-
Bug
-
Status: Closed
-
Minor
-
Resolution: Fixed
-
0.23.0
-
Reviewed
Description
In class org.apache.hadoop.yarn.applications.distributedshell.ApplicationMaster
private void connectToCM() { String cmIpPortStr = container.getNodeId().getHost() + ":" + container.getNodeId().getPort(); InetSocketAddress cmAddress = NetUtils.createSocketAddr(cmIpPortStr); LOG.info("Connecting to ResourceManager at " + cmIpPortStr); this.cm = ((ContainerManager) rpc.getProxy(ContainerManager.class, cmAddress, conf)); }