aboutsummaryrefslogtreecommitdiff
path: root/core/src/test
diff options
context:
space:
mode:
authorBurak Yavuz <brkyvz@gmail.com>2015-04-28 23:05:02 -0700
committerPatrick Wendell <patrick@databricks.com>2015-04-28 23:05:02 -0700
commitf98773a90ded0e408af6bbd85fafbaffbc5b825f (patch)
treed0bf94ede72b3f827e4b62a89585614072815473 /core/src/test
parent271c4c621d91d3f610ae89e5d2e5dab1a2009ca6 (diff)
downloadspark-f98773a90ded0e408af6bbd85fafbaffbc5b825f.tar.gz
spark-f98773a90ded0e408af6bbd85fafbaffbc5b825f.tar.bz2
spark-f98773a90ded0e408af6bbd85fafbaffbc5b825f.zip
[SPARK-7205] Support `.ivy2/local` and `.m2/repositories/` in --packages
In addition, I made a small change that will allow users to import 2 different artifacts with the same name. That change is made in `[organization]_[artifact]-[revision].[ext]`. This used to be only `[artifact].[ext]` which might have caused collisions between artifacts with the same artifactId, but different groupId's. cc pwendell Author: Burak Yavuz <brkyvz@gmail.com> Closes #5755 from brkyvz/local-caches and squashes the following commits: c47c9c5 [Burak Yavuz] Small fixes to --packages
Diffstat (limited to 'core/src/test')
-rw-r--r--core/src/test/scala/org/apache/spark/deploy/SparkSubmitUtilsSuite.scala27
1 files changed, 14 insertions, 13 deletions
diff --git a/core/src/test/scala/org/apache/spark/deploy/SparkSubmitUtilsSuite.scala b/core/src/test/scala/org/apache/spark/deploy/SparkSubmitUtilsSuite.scala
index 8bcca92609..1b2b699cb1 100644
--- a/core/src/test/scala/org/apache/spark/deploy/SparkSubmitUtilsSuite.scala
+++ b/core/src/test/scala/org/apache/spark/deploy/SparkSubmitUtilsSuite.scala
@@ -19,6 +19,8 @@ package org.apache.spark.deploy
import java.io.{PrintStream, OutputStream, File}
+import org.apache.ivy.core.settings.IvySettings
+
import scala.collection.mutable.ArrayBuffer
import org.scalatest.{BeforeAndAfterAll, FunSuite}
@@ -56,24 +58,23 @@ class SparkSubmitUtilsSuite extends FunSuite with BeforeAndAfterAll {
}
test("create repo resolvers") {
- val resolver1 = SparkSubmitUtils.createRepoResolvers(None)
+ val settings = new IvySettings
+ val res1 = SparkSubmitUtils.createRepoResolvers(None, settings)
// should have central and spark-packages by default
- assert(resolver1.getResolvers.size() === 2)
- assert(resolver1.getResolvers.get(0).asInstanceOf[IBiblioResolver].getName === "central")
- assert(resolver1.getResolvers.get(1).asInstanceOf[IBiblioResolver].getName === "spark-packages")
+ assert(res1.getResolvers.size() === 4)
+ assert(res1.getResolvers.get(0).asInstanceOf[IBiblioResolver].getName === "local-m2-cache")
+ assert(res1.getResolvers.get(1).asInstanceOf[IBiblioResolver].getName === "local-ivy-cache")
+ assert(res1.getResolvers.get(2).asInstanceOf[IBiblioResolver].getName === "central")
+ assert(res1.getResolvers.get(3).asInstanceOf[IBiblioResolver].getName === "spark-packages")
val repos = "a/1,b/2,c/3"
- val resolver2 = SparkSubmitUtils.createRepoResolvers(Option(repos))
- assert(resolver2.getResolvers.size() === 5)
+ val resolver2 = SparkSubmitUtils.createRepoResolvers(Option(repos), settings)
+ assert(resolver2.getResolvers.size() === 7)
val expected = repos.split(",").map(r => s"$r/")
resolver2.getResolvers.toArray.zipWithIndex.foreach { case (resolver: IBiblioResolver, i) =>
- if (i == 0) {
- assert(resolver.getName === "central")
- } else if (i == 1) {
- assert(resolver.getName === "spark-packages")
- } else {
- assert(resolver.getName === s"repo-${i - 1}")
- assert(resolver.getRoot === expected(i - 2))
+ if (i > 3) {
+ assert(resolver.getName === s"repo-${i - 3}")
+ assert(resolver.getRoot === expected(i - 4))
}
}
}