You are viewing a plain text version of this content. The canonical link for it is here.
Posted to common-commits@hadoop.apache.org by li...@apache.org on 2016/11/22 23:11:33 UTC
[39/50] [abbrv] hadoop git commit: YARN-5859.
TestResourceLocalizationService#testParallelDownloadAttemptsForPublicResource
sometimes fails. Contributed by Eric Badger
YARN-5859. TestResourceLocalizationService#testParallelDownloadAttemptsForPublicResource sometimes fails. Contributed by Eric Badger
Project: http://git-wip-us.apache.org/repos/asf/hadoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/hadoop/commit/009452bb
Tree: http://git-wip-us.apache.org/repos/asf/hadoop/tree/009452bb
Diff: http://git-wip-us.apache.org/repos/asf/hadoop/diff/009452bb
Branch: refs/heads/HADOOP-13345
Commit: 009452bb6dbe5dffb0b304d67a2f360fe0eee1e2
Parents: 3eb7b68
Author: Jason Lowe <jl...@apache.org>
Authored: Mon Nov 21 16:36:08 2016 +0000
Committer: Jason Lowe <jl...@apache.org>
Committed: Mon Nov 21 16:36:08 2016 +0000
----------------------------------------------------------------------
.../TestResourceLocalizationService.java | 18 +++++++++---------
1 file changed, 9 insertions(+), 9 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/hadoop/blob/009452bb/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
----------------------------------------------------------------------
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..42479ea 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 class TestResourceLocalizationService {
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 class TestResourceLocalizationService {
createContainerLocalizationEvent(container2,
LocalResourceVisibility.PRIVATE, req));
Assert
- .assertTrue(waitForPrivateDownloadToStart(rls, localizerId2, 1, 200));
+ .assertTrue(waitForPrivateDownloadToStart(rls, localizerId2, 1, 5000));
// Retrieving localized resource.
LocalResourcesTracker tracker =
@@ -1944,7 +1944,7 @@ public class TestResourceLocalizationService {
Assert
.assertTrue(waitForResourceState(lr, rls, req,
LocalResourceVisibility.PRIVATE, user, appId, ResourceState.FAILED,
- 200));
+ 5000));
Assert.assertTrue(lr.getState().equals(ResourceState.FAILED));
Assert.assertEquals(0, localizerRunner1.scheduled.size());
@@ -2060,7 +2060,7 @@ public class TestResourceLocalizationService {
// Now waiting for resource download to start. Here actual will not start
// Only the resources will be populated into pending list.
Assert
- .assertTrue(waitForPrivateDownloadToStart(rls, localizerId1, 2, 500));
+ .assertTrue(waitForPrivateDownloadToStart(rls, localizerId1, 2, 5000));
// Validating user and application cache paths
@@ -2210,10 +2210,10 @@ public class TestResourceLocalizationService {
// Waiting for resource to change into DOWNLOADING state.
Assert.assertTrue(waitForResourceState(null, spyService, req,
LocalResourceVisibility.PUBLIC, user, null, ResourceState.DOWNLOADING,
- 200));
+ 5000));
// Waiting for download to start.
- Assert.assertTrue(waitForPublicDownloadToStart(spyService, 1, 200));
+ Assert.assertTrue(waitForPublicDownloadToStart(spyService, 1, 5000));
LocalizedResource lr =
getLocalizedResource(spyService, req, LocalResourceVisibility.PUBLIC,
@@ -2236,7 +2236,7 @@ public class TestResourceLocalizationService {
// Waiting for download to start. This should return false as new download
// will not start
- Assert.assertFalse(waitForPublicDownloadToStart(spyService, 2, 100));
+ Assert.assertFalse(waitForPublicDownloadToStart(spyService, 2, 5000));
// Now Failing the resource download. As a part of it
// resource state is changed and then lock is released.
@@ -2248,7 +2248,7 @@ public class TestResourceLocalizationService {
// 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.
@@ -2268,7 +2268,7 @@ public class TestResourceLocalizationService {
dispatcher1.getEventHandler().handle(localizerEvent);
// Waiting for download to start. This should return false as new download
// will not start
- Assert.assertFalse(waitForPublicDownloadToStart(spyService, 1, 100));
+ Assert.assertFalse(waitForPublicDownloadToStart(spyService, 1, 5000));
// Checking available permits now.
Assert.assertEquals(1, lr.sem.availablePermits());
---------------------------------------------------------------------
To unsubscribe, e-mail: common-commits-unsubscribe@hadoop.apache.org
For additional commands, e-mail: common-commits-help@hadoop.apache.org