|
38 | 38 | import org.apache.hadoop.yarn.api.records.Priority; |
39 | 39 | import org.apache.hadoop.yarn.conf.YarnConfiguration; |
40 | 40 | import org.apache.hadoop.yarn.exceptions.YarnException; |
41 | | -import org.apache.hadoop.yarn.server.federation.policies.manager.UniformBroadcastPolicyManager; |
42 | 41 | import org.apache.hadoop.yarn.server.federation.store.impl.MemoryFederationStateStore; |
43 | 42 | import org.apache.hadoop.yarn.server.federation.store.records.ApplicationHomeSubCluster; |
44 | 43 | import org.apache.hadoop.yarn.server.federation.store.records.GetApplicationHomeSubClusterRequest; |
@@ -290,7 +289,7 @@ public void testSubmitApplicationTwoBadOneGood() throws Exception { |
290 | 289 | LOG.info("Test submitApplication with two bad, one good SC."); |
291 | 290 | setupCluster(Arrays.asList(bad1, bad2, good)); |
292 | 291 | final ApplicationId appId = |
293 | | - ApplicationId.newInstance(System.currentTimeMillis(), 1); |
| 292 | + ApplicationId.newInstance(System.currentTimeMillis(), 1); |
294 | 293 |
|
295 | 294 | // Use the TestSequentialRouterPolicy strategy, |
296 | 295 | // which will sort the SubClusterId because good=0, bad1=1, bad2=2 |
@@ -324,7 +323,8 @@ private void checkSubmitSubCluster(ApplicationId appId, SubClusterId expectSubCl |
324 | 323 | stateStore.getApplicationHomeSubCluster(getAppRequest); |
325 | 324 | Assert.assertNotNull(getAppResponse); |
326 | 325 | Assert.assertNotNull(getAppResponse); |
327 | | - ApplicationHomeSubCluster responseHomeSubCluster = getAppResponse.getApplicationHomeSubCluster(); |
| 326 | + ApplicationHomeSubCluster responseHomeSubCluster = |
| 327 | + getAppResponse.getApplicationHomeSubCluster(); |
328 | 328 | Assert.assertNotNull(responseHomeSubCluster); |
329 | 329 | SubClusterId respSubClusterId = responseHomeSubCluster.getHomeSubCluster(); |
330 | 330 | Assert.assertEquals(expectSubCluster, respSubClusterId); |
|
0 commit comments