/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/main/java/org/apache/hadoop/yarn/client/ |
H A D | ClientRMProxy.java | 90 return conf.getSocketAddr(YarnConfiguration.RM_ADDRESS, in getRMAddress() 131 return getTokenService(conf, YarnConfiguration.RM_ADDRESS, in getRMDelegationTokenService()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-common/src/test/java/org/apache/hadoop/yarn/conf/ |
H A D | TestHAUtil.java | 160 HAUtil.addSuffix(YarnConfiguration.RM_ADDRESS, RM1_NODE_ID); in testVerifyAndSetConfiguration() 190 HAUtil.getConfKeyForRMInstance(YarnConfiguration.RM_ADDRESS, conf) in testGetConfKeyForRMInstance()
|
H A D | TestYarnConfiguration.java | 52 conf.set(YarnConfiguration.RM_ADDRESS, "rmtesting:9999"); in testRMWebUrlSpecified()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapreduce/ |
H A D | MiniHadoopClusterManager.java | 170 conf.set(YarnConfiguration.RM_ADDRESS, MiniYARNCluster.getHostname() in start() 192 YarnConfiguration.RM_ADDRESS).split(":")[1]); in start()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/main/java/org/apache/hadoop/mapred/ |
H A D | Master.java | 59 YarnConfiguration.RM_ADDRESS, in getMasterAddress()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-core/src/test/java/org/apache/hadoop/mapred/ |
H A D | TestMaster.java | 63 conf.set(YarnConfiguration.RM_ADDRESS, "foo1.com:8192"); in testGetMasterAddress()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-api/src/main/java/org/apache/hadoop/yarn/conf/ |
H A D | HAUtil.java | 120 msg.append(addSuffix(YarnConfiguration.RM_ADDRESS, id) + " "); in verifyAndSetCurrentRMHAId() 183 String key = addSuffix(YarnConfiguration.RM_ADDRESS, rmId); in getRMHAId()
|
H A D | YarnConfiguration.java | 131 public static final String RM_ADDRESS = field in YarnConfiguration 480 RM_ADDRESS, 488 RM_ADDRESS, 1861 if (addressPrefix.equals(YarnConfiguration.RM_ADDRESS)) { in getRMDefaultPortNumber()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapred/ |
H A D | TestMiniMRClientCluster.java | 99 String rmAddress1 = mrCluster.getConfig().get(YarnConfiguration.RM_ADDRESS); in testRestart() 116 String rmAddress2 = mrCluster.getConfig().get(YarnConfiguration.RM_ADDRESS); in testRestart()
|
H A D | TestClientRedirect.java | 152 conf.set(YarnConfiguration.RM_ADDRESS, RMADDRESS); in testRedirect()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/test/java/org/apache/hadoop/yarn/server/resourcemanager/ |
H A D | TestRMHA.java | 685 assertEquals("RPC address not set for " + YarnConfiguration.RM_ADDRESS, in innerTestHAWithRMHostName() 687 conf.get(HAUtil.addSuffix(YarnConfiguration.RM_ADDRESS, RM1_NODE_ID))); in innerTestHAWithRMHostName() 688 assertEquals("RPC address not set for " + YarnConfiguration.RM_ADDRESS, in innerTestHAWithRMHostName() 690 conf.get(HAUtil.addSuffix(YarnConfiguration.RM_ADDRESS, RM2_NODE_ID))); in innerTestHAWithRMHostName()
|
H A D | TestRMEmbeddedElector.java | 50 setConfForRM(rmId, YarnConfiguration.RM_ADDRESS, "0.0.0.0:" + in setRpcAddressForRM()
|
H A D | QueueACLsTestBase.java | 79 YarnConfiguration.RM_ADDRESS, YarnConfiguration.DEFAULT_RM_ADDRESS, in setup()
|
H A D | TestApplicationACLs.java | 88 YarnConfiguration.RM_ADDRESS,
|
H A D | TestClientRMTokens.java | 487 return conf.getSocketAddr(YarnConfiguration.RM_ADDRESS, in getBindAddress()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-tests/src/test/java/org/apache/hadoop/yarn/server/ |
H A D | MiniYARNCluster.java | 275 conf.set(YarnConfiguration.RM_ADDRESS, hostname + ":0"); in setNonHARMConfigurationWithEphemeralPorts() 333 getConfig().get(YarnConfiguration.RM_ADDRESS)); in startResourceManager() 452 getConfig().get(YarnConfiguration.RM_ADDRESS)); in serviceStart()
|
/dports/devel/spark/spark-2.1.1/yarn/src/test/scala/org/apache/spark/deploy/yarn/ |
H A D | BaseYarnClusterSuite.scala | 107 while (config.get(YarnConfiguration.RM_ADDRESS).split(":")(1) == "0") {
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-unmanaged-am-launcher/src/test/java/org/apache/hadoop/yarn/applications/unmanagedamlauncher/ |
H A D | TestUnmanagedAMLauncher.java | 70 yarnClusterConfig.get(YarnConfiguration.RM_ADDRESS)); in setup()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-jobclient/src/test/java/org/apache/hadoop/mapreduce/v2/ |
H A D | MiniMRYarnCluster.java | 238 getConfig().get(YarnConfiguration.RM_ADDRESS)); in serviceStart()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/ |
H A D | TestRMFailover.java | 77 setConfForRM(rmId, YarnConfiguration.RM_ADDRESS, "0.0.0.0:" + in setRpcAddressForRM()
|
H A D | ProtocolHATestBase.java | 169 setConfForRM(rmId, YarnConfiguration.RM_ADDRESS, "0.0.0.0:" + in setRpcAddressForRM()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/ |
H A D | ClientRMService.java | 241 YarnConfiguration.RM_ADDRESS, in serviceStart() 258 YarnConfiguration.RM_ADDRESS, in getBindAddress()
|
H A D | ResourceManager.java | 1226 return conf.getSocketAddr(YarnConfiguration.RM_ADDRESS, in getBindAddress()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/main/java/org/apache/hadoop/yarn/client/api/impl/ |
H A D | YarnClientImpl.java | 366 YarnConfiguration.RM_ADDRESS, in getTimelineDelegationTokenRenewer()
|
/dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-resourcemanager/src/main/java/org/apache/hadoop/yarn/server/resourcemanager/recovery/ |
H A D | ZKRMStateStore.java | 220 YarnConfiguration.RM_ADDRESS, in constructZkRootNodeACL()
|