-
Notifications
You must be signed in to change notification settings - Fork 9.1k
YARN-10553. Refactor TestDistributedShell #2581
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
💔 -1 overall
This message was automatically generated. |
}, 10, 60000); | ||
} | ||
|
||
|
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Avoid double spaces? A high level javadoc wouldn't hurt either.
...test/java/org/apache/hadoop/yarn/applications/distributedshell/DistributedShellBaseTest.java
Outdated
Show resolved
Hide resolved
...test/java/org/apache/hadoop/yarn/applications/distributedshell/DistributedShellBaseTest.java
Outdated
Show resolved
Hide resolved
...test/java/org/apache/hadoop/yarn/applications/distributedshell/DistributedShellBaseTest.java
Outdated
Show resolved
Hide resolved
...test/java/org/apache/hadoop/yarn/applications/distributedshell/DistributedShellBaseTest.java
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@amahussein Could you have time to fix the conflicts?
💔 -1 overall
This message was automatically generated. |
yarnClient.stop(); | ||
yarnClient.waitForServiceToStop(clientTimeout); | ||
//yarnClient.waitForServiceToStop(clientTimeout); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Testing?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Oh! I forgot to delete that line.
Waiting for the service to stop is not necessary.
@goiri the code changes fix {{testDSShellWithEnforceExecutionType}}. The fix was to get rid of the equality in the check, and change the application command to |
CC: @iwasakims . This includes a fix to |
That makes sense, does it make sense to make the assert more general than an equality instead of getting rid of the equality? |
...er/hadoop-yarn-server-tests/src/test/java/org/apache/hadoop/yarn/server/MiniYARNCluster.java
Outdated
Show resolved
Hide resolved
In |
💔 -1 overall
This message was automatically generated. |
Is the fix of o.a.h.tools.dynamometer.Cliet related to TestDistributedShell? It should be addressed in another JIRA if not. |
...c/test/java/org/apache/hadoop/yarn/applications/distributedshell/TestDSShellTimelineV10.java
Outdated
Show resolved
Hide resolved
🎊 +1 overall
This message was automatically generated. |
yarnClient.init(new Configuration(getYarnClusterConfiguration())); | ||
yarnClient.start(); | ||
|
||
waitForContainersLaunch(yarnClient, 2, appAttemptReportRef, |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
nContainers should be 3 if need to take AM container into account?
@@ -1330,7 +1330,7 @@ private void setAMResourceCapability(ApplicationSubmissionContext appContext, | |||
} | |||
if (amVCores == -1) { | |||
amVCores = DEFAULT_AM_VCORES; | |||
LOG.warn("AM vcore not specified, use " + DEFAULT_AM_VCORES | |||
LOG.warn("AM vcore not specified, use {}" + DEFAULT_AM_VCORES |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
looks like misused place holder.
Thank for working on this, @amahussein. LGTM overall pending some nits. While it is too late here, it is hard to follow which part of the TestDistributedShell is modified if splitting the class and refactoring are mixed up in a single commit. Doing one thing in one PR makes reviewing and cherry-picking easier. |
I think there is a gap between the PR and the above description of YARN-10553. Just splitting the TestDistributedShell does not reduce code nor minicluster ramp-up time. It would be nice to update the JIRA description reflecting what is addressed. |
That's good point @iwasakims . Sorry that I made it hard. |
I will update the Jira description. |
Thanks for the review @iwasakims and @goiri ! |
🎊 +1 overall
This message was automatically generated. |
The latest commit seemed to introduce errors.
|
Hey @iwasakims!
This could be something that missing in the configurations of the unitTest or a bug in either timelineserviceV1.5 or timelineserviceV2.0 I haven't figured it yet, but probably this would need filing another jira. |
@iwasakims and @goiri Do you have insights what could the problem be ? |
I did an experiment on the original if you run mvn test -Dtest=TestDistributedShell#testDSShellWithoutDomainV1_5;
mvn test -Dtest=TestDistributedShell#testDSShellWithoutDomainV2 Then the testDSShellWithoutDomainV2 will fail with the same exception. It seems that there was an old bug and not introduced by my changes. |
My stack trace indicates that TestDSTimelineV20 is configured to use HDFS but there is no running MiniDFSCluster. YARN daemons are failed to start due to this. |
Running |
It is easily surfaced by just running |
...test/java/org/apache/hadoop/yarn/applications/distributedshell/DistributedShellBaseTest.java
Outdated
Show resolved
Hide resolved
🎊 +1 overall
This message was automatically generated. |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks for the update, @amahussein. +1.
Thanks for the review @iwasakims and @goiri |
(cherry picked from commit 890f2da) Conflicts: hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/TestDSWithMultipleNodeManager.java hadoop-yarn-project/hadoop-yarn/hadoop-yarn-applications/hadoop-yarn-applications-distributedshell/src/test/java/org/apache/hadoop/yarn/applications/distributedshell/TestDistributedShell.java
NOTICE
Please create an issue in ASF JIRA before opening a pull request,
and you need to set the title of the pull request which starts with
the corresponding JIRA issue number. (e.g. HADOOP-XXXXX. Fix a typo in YYY.)
For more details, please see https://cwiki.apache.org/confluence/display/HADOOP/How+To+Contribute