diff --git a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/test/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/localizer/TestResourceLocalizationService.java b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/test/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/localizer/TestResourceLocalizationService.java index 13ba2c1..4ebf9ba 100644 --- a/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/test/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/localizer/TestResourceLocalizationService.java +++ b/hadoop-yarn-project/hadoop-yarn/hadoop-yarn-server/hadoop-yarn-server-nodemanager/src/test/java/org/apache/hadoop/yarn/server/nodemanager/containermanager/localizer/TestResourceLocalizationService.java @@ -1888,7 +1888,7 @@ public void testParallelDownloadAttemptsForPrivateResource() throws Exception { createContainerLocalizationEvent(container1, LocalResourceVisibility.PRIVATE, req)); Assert - .assertTrue(waitForPrivateDownloadToStart(rls, localizerId1, 1, 200)); + .assertTrue(waitForPrivateDownloadToStart(rls, localizerId1, 1, 5000)); // Container - 2 now makes the request. ContainerImpl container2 = createMockContainer(user, 2); @@ -1902,7 +1902,7 @@ public void testParallelDownloadAttemptsForPrivateResource() throws Exception { createContainerLocalizationEvent(container2, LocalResourceVisibility.PRIVATE, req)); Assert - .assertTrue(waitForPrivateDownloadToStart(rls, localizerId2, 1, 200)); + .assertTrue(waitForPrivateDownloadToStart(rls, localizerId2, 1, 5000)); // Retrieving localized resource. LocalResourcesTracker tracker = @@ -2213,7 +2213,7 @@ public void testParallelDownloadAttemptsForPublicResource() throws Exception { 200)); // Waiting for download to start. - Assert.assertTrue(waitForPublicDownloadToStart(spyService, 1, 200)); + Assert.assertTrue(waitForPublicDownloadToStart(spyService, 1, 5000)); LocalizedResource lr = getLocalizedResource(spyService, req, LocalResourceVisibility.PUBLIC, @@ -2248,7 +2248,7 @@ public void testParallelDownloadAttemptsForPublicResource() throws Exception { // Waiting for resource to change into FAILED state. Assert.assertTrue(waitForResourceState(lr, spyService, req, - LocalResourceVisibility.PUBLIC, user, null, ResourceState.FAILED, 200)); + LocalResourceVisibility.PUBLIC, user, null, ResourceState.FAILED, 5000)); // releasing lock as a part of download failed process. lr.unlock(); // removing pending download request.