| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/ |
| H A D | TestDistributedShell.java | 62 protected MiniYARNCluster yarnCluster = null; field in TestDistributedShell
85 if (yarnCluster == null) { in setupInternal()
86 yarnCluster = in setupInternal()
89 yarnCluster.init(conf); in setupInternal()
91 yarnCluster.start(); in setupInternal()
131 if (yarnCluster != null) { in tearDown()
133 yarnCluster.stop(); in tearDown()
135 yarnCluster = null; in tearDown()
247 TimelineEntities entitiesAttempts = yarnCluster in testDSShell()
265 TimelineEntities entities = yarnCluster in testDSShell()
[all …]
|
| H A D | TestDistributedShellWithNodeLabels.java | 51 RMContext rmContext = distShellTest.yarnCluster.getResourceManager(0).getRMContext(); in initializeNodeLabels()
73 NodeManager mgr = distShellTest.yarnCluster.getNodeManager(i); in initializeNodeLabels()
114 new Client(new Configuration(distShellTest.yarnCluster.getConfig())); in testDSShellWithNodeLabelExpression()
146 distShellTest.yarnCluster.getNodeManager(i).getNMContext() in run()
|
| /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 | 55 protected static MiniYARNCluster yarnCluster = null; field in TestUnmanagedAMLauncher
62 if (yarnCluster == null) { in setup()
63 yarnCluster = new MiniYARNCluster( in setup()
65 yarnCluster.init(conf); in setup()
66 yarnCluster.start(); in setup()
68 Configuration yarnClusterConfig = yarnCluster.getConfig(); in setup()
102 if (yarnCluster != null) { in tearDown()
104 yarnCluster.stop(); in tearDown()
106 yarnCluster = null; in tearDown()
147 new UnmanagedAMLauncher(new Configuration(yarnCluster.getConfig())) { in testUMALauncher()
[all …]
|
| /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 | TestDiskFailures.java | 69 private static MiniYARNCluster yarnCluster; field in TestDiskFailures
83 if (yarnCluster != null) { in teardown()
84 yarnCluster.stop(); in teardown()
85 yarnCluster = null; in teardown()
157 if (yarnCluster != null) { in testDirsFailures()
158 yarnCluster.stop(); in testDirsFailures()
163 yarnCluster = new MiniYARNCluster(TestDiskFailures.class.getName(), in testDirsFailures()
165 yarnCluster.init(conf); in testDirsFailures()
166 yarnCluster.start(); in testDirsFailures()
168 NodeManager nm = yarnCluster.getNodeManager(0); in testDirsFailures()
[all …]
|
| H A D | TestContainerManagerSecurity.java | 94 private static MiniYARNCluster yarnCluster; field in TestContainerManagerSecurity
150 yarnCluster.init(conf); in testContainerManager()
151 yarnCluster.start(); in testContainerManager()
163 if (yarnCluster != null) { in testContainerManager()
164 yarnCluster.stop(); in testContainerManager()
165 yarnCluster = null; in testContainerManager()
175 yarnCluster.init(conf); in testContainerManagerWithEpoch()
176 yarnCluster.start(); in testContainerManagerWithEpoch()
182 if (yarnCluster != null) { in testContainerManagerWithEpoch()
183 yarnCluster.stop(); in testContainerManagerWithEpoch()
[all …]
|
| /dports/devel/spark/spark-2.1.1/yarn/src/test/scala/org/apache/spark/deploy/yarn/ |
| H A D | BaseYarnClusterSuite.scala | 59 private var yarnCluster: MiniYARNCluster = _
87 yarnCluster = new MiniYARNCluster(getClass().getName(), 1, 1, 1)
88 yarnCluster.init(yarnConf)
89 yarnCluster.start()
105 val config = yarnCluster.getConfig()
125 yarnCluster.stop()
224 yarnCluster.getConfig().asScala.foreach { e =>
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-client/src/test/java/org/apache/hadoop/yarn/client/api/impl/ |
| H A D | TestNMClient.java | 75 MiniYARNCluster yarnCluster = null; field in TestNMClient
88 yarnCluster = in setup()
90 yarnCluster.init(conf); in setup()
91 yarnCluster.start(); in setup()
92 assertNotNull(yarnCluster); in setup()
93 assertEquals(STATE.STARTED, yarnCluster.getServiceState()); in setup()
138 yarnCluster.getResourceManager().getRMContext().getRMApps() in setup()
190 yarnCluster.stop(); in tearDown()
|
| H A D | TestAMRMClient.java | 102 static MiniYARNCluster yarnCluster = null; field in TestAMRMClient
131 yarnCluster.init(conf); in setup()
132 yarnCluster.start(); in setup()
189 yarnCluster.getResourceManager().getRMContext().getRMApps() in startApp()
221 if (yarnCluster != null && yarnCluster.getServiceState() == STATE.STARTED) { in tearDown()
222 yarnCluster.stop(); in tearDown()
933 yarnCluster.getResourceManager().getRMContext() in testAMRMClientOnAMRMTokenRollOver()
991 SecurityUtil.setTokenService(newVersionToken, yarnCluster in testAMRMClientOnAMRMTokenRollOver()
1002 yarnCluster.getResourceManager().getApplicationMasterService() in testAMRMClientOnAMRMTokenRollOver()
1031 SecurityUtil.setTokenService(amrmToken_2, yarnCluster in testAMRMClientOnAMRMTokenRollOver()
[all …]
|
| /dports/devel/hadoop2/hadoop-2.7.2-src/hadoop-mapreduce-project/hadoop-mapreduce-client/hadoop-mapreduce-client-app/src/test/java/org/apache/hadoop/mapreduce/jobhistory/ |
| H A D | TestJobHistoryEventHandler.java | 492 MiniYARNCluster yarnCluster = null; in testTimelineEventHandling() local
495 yarnCluster = new MiniYARNCluster( in testTimelineEventHandling()
497 yarnCluster.init(conf); in testTimelineEventHandling()
498 yarnCluster.start(); in testTimelineEventHandling()
503 yarnCluster.getApplicationHistoryServer().getPort()); in testTimelineEventHandling()
507 TimelineStore ts = yarnCluster.getApplicationHistoryServer() in testTimelineEventHandling()
650 if (yarnCluster != null) { in testTimelineEventHandling()
651 yarnCluster.stop(); in testTimelineEventHandling()
|