-
- Downloads
[SPARK-2778] [yarn] Add yarn integration tests.
This patch adds a couple of, currently, very simple integration tests to make sure both client and cluster modes are working. The tests don't do much yet other than run a simple job, but the plan is to enhance them after we get the framework in. The cluster tests are noisy, so redirect all log output to a file like other tests do. Copying the conf around sucks but it's less work than messing with maven/sbt and having to clean up other projects. Note the test is only added for yarn-stable. The code compiles against yarn-alpha but there are two issues I ran into that I could not overcome: - an old netty dependency kept creeping into the classpath and causing akka to not work, when using sbt; the old netty was correctly suppressed under maven. - MiniYARNCluster kept failing to execute containers because it did not create the NM's local dir itself; this is apparently a known behavior, but I'm not sure how to work around it. None of those issues are present with the stable Yarn. Also, these tests are a little slow to run. Apparently Spark doesn't yet tag tests (so that these could be isolated in a "slow" batch), so this is something to keep in mind. Author: Marcelo Vanzin <vanzin@cloudera.com> Closes #2257 from vanzin/yarn-tests and squashes the following commits: 6d5b84e [Marcelo Vanzin] Fix wrong system property being set. 8b0933d [Marcelo Vanzin] Merge branch 'master' into yarn-tests 5c2b56f [Marcelo Vanzin] Use custom log4j conf for Yarn containers. ec73f17 [Marcelo Vanzin] More review feedback. 67f5b02 [Marcelo Vanzin] Review feedback. f01517c [Marcelo Vanzin] Review feedback. 68fbbbf [Marcelo Vanzin] Use older constructor available in older Hadoop releases. d07ef9a [Marcelo Vanzin] Merge branch 'master' into yarn-tests add8416 [Marcelo Vanzin] [SPARK-2778] [yarn] Add yarn integration tests.
Showing
- pom.xml 30 additions, 1 deletionpom.xml
- yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ApplicationMaster.scala 5 additions, 5 deletions...cala/org/apache/spark/deploy/yarn/ApplicationMaster.scala
- yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ClientBase.scala 1 addition, 1 deletion.../main/scala/org/apache/spark/deploy/yarn/ClientBase.scala
- yarn/common/src/main/scala/org/apache/spark/deploy/yarn/ExecutorRunnableUtil.scala 1 addition, 1 deletion...a/org/apache/spark/deploy/yarn/ExecutorRunnableUtil.scala
- yarn/pom.xml 1 addition, 2 deletionsyarn/pom.xml
- yarn/stable/pom.xml 9 additions, 0 deletionsyarn/stable/pom.xml
- yarn/stable/src/test/resources/log4j.properties 28 additions, 0 deletionsyarn/stable/src/test/resources/log4j.properties
- yarn/stable/src/test/scala/org/apache/spark/deploy/yarn/YarnClusterSuite.scala 154 additions, 0 deletions...scala/org/apache/spark/deploy/yarn/YarnClusterSuite.scala
Loading
Please register or sign in to comment