Skip to content
Closed
Prev Previous commit
Merge branch 'master' of github.com:apache/spark into concurrent-sql-…
…executions

Conflicts:
	core/src/test/scala/org/apache/spark/ThreadingSuite.scala
  • Loading branch information
Andrew Or committed Sep 14, 2015
commit 75a8d904f9935226df6872d15f99c8344615213c
8 changes: 3 additions & 5 deletions core/src/test/scala/org/apache/spark/ThreadingSuite.scala
Original file line number Diff line number Diff line change
Expand Up @@ -147,13 +147,12 @@ class ThreadingSuite extends SparkFunSuite with LocalSparkContext with Logging {
}.start()
}
sem.acquire(2)
throwable.foreach { t => throw t }
throwable.foreach { t => throw improveStackTrace(t) }
if (ThreadingSuiteState.failed.get()) {
logError("Waited 1 second without seeing runningThreads = 4 (it was " +
ThreadingSuiteState.runningThreads.get() + "); failing test")
fail("One or more threads didn't see runningThreads = 4")
}
throwable.foreach { t => throw improveStackTrace(t) }
}

test("set local properties in different thread") {
Expand All @@ -179,8 +178,8 @@ class ThreadingSuite extends SparkFunSuite with LocalSparkContext with Logging {
threads.foreach(_.start())

sem.acquire(5)
assert(sc.getLocalProperty("test") === null)
throwable.foreach { t => throw improveStackTrace(t) }
assert(sc.getLocalProperty("test") === null)
}

test("set and get local properties in parent-children thread") {
Expand Down Expand Up @@ -208,10 +207,9 @@ class ThreadingSuite extends SparkFunSuite with LocalSparkContext with Logging {
threads.foreach(_.start())

sem.acquire(5)
throwable.foreach { t => throw t }
throwable.foreach { t => throw improveStackTrace(t) }
assert(sc.getLocalProperty("test") === "parent")
assert(sc.getLocalProperty("Foo") === null)
throwable.foreach { t => throw improveStackTrace(t) }
}

test("mutation in parent local property does not affect child (SPARK-10563)") {
Expand Down
You are viewing a condensed version of this merge commit. You can view the full changes here.