Home
last modified time | relevance | path

Searched refs:RM_ADDRESS (Results 1 – 25 of 27) sorted by relevance

12

/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 DClientRMProxy.java90 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 DTestHAUtil.java160 HAUtil.addSuffix(YarnConfiguration.RM_ADDRESS, RM1_NODE_ID); in testVerifyAndSetConfiguration()
190 HAUtil.getConfKeyForRMInstance(YarnConfiguration.RM_ADDRESS, conf) in testGetConfKeyForRMInstance()
H A DTestYarnConfiguration.java52 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 DMiniHadoopClusterManager.java170 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 DMaster.java59 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 DTestMaster.java63 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 DHAUtil.java120 msg.append(addSuffix(YarnConfiguration.RM_ADDRESS, id) + " "); in verifyAndSetCurrentRMHAId()
183 String key = addSuffix(YarnConfiguration.RM_ADDRESS, rmId); in getRMHAId()
H A DYarnConfiguration.java131 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 DTestMiniMRClientCluster.java99 String rmAddress1 = mrCluster.getConfig().get(YarnConfiguration.RM_ADDRESS); in testRestart()
116 String rmAddress2 = mrCluster.getConfig().get(YarnConfiguration.RM_ADDRESS); in testRestart()
H A DTestClientRedirect.java152 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 DTestRMHA.java685 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 DTestRMEmbeddedElector.java50 setConfForRM(rmId, YarnConfiguration.RM_ADDRESS, "0.0.0.0:" + in setRpcAddressForRM()
H A DQueueACLsTestBase.java79 YarnConfiguration.RM_ADDRESS, YarnConfiguration.DEFAULT_RM_ADDRESS, in setup()
H A DTestApplicationACLs.java88 YarnConfiguration.RM_ADDRESS,
H A DTestClientRMTokens.java487 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 DMiniYARNCluster.java275 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 DBaseYarnClusterSuite.scala107 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 DTestUnmanagedAMLauncher.java70 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 DMiniMRYarnCluster.java238 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 DTestRMFailover.java77 setConfForRM(rmId, YarnConfiguration.RM_ADDRESS, "0.0.0.0:" + in setRpcAddressForRM()
H A DProtocolHATestBase.java169 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 DClientRMService.java241 YarnConfiguration.RM_ADDRESS, in serviceStart()
258 YarnConfiguration.RM_ADDRESS, in getBindAddress()
H A DResourceManager.java1226 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 DYarnClientImpl.java366 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 DZKRMStateStore.java220 YarnConfiguration.RM_ADDRESS, in constructZkRootNodeACL()

12