aboutsummaryrefslogtreecommitdiff
path: root/core/src/test/scala/org/apache/spark/util/TimeStampedHashMapSuite.scala
diff options
context:
space:
mode:
Diffstat (limited to 'core/src/test/scala/org/apache/spark/util/TimeStampedHashMapSuite.scala')
-rw-r--r--core/src/test/scala/org/apache/spark/util/TimeStampedHashMapSuite.scala4
1 files changed, 2 insertions, 2 deletions
diff --git a/core/src/test/scala/org/apache/spark/util/TimeStampedHashMapSuite.scala b/core/src/test/scala/org/apache/spark/util/TimeStampedHashMapSuite.scala
index 25fc15dd54..fd9add7690 100644
--- a/core/src/test/scala/org/apache/spark/util/TimeStampedHashMapSuite.scala
+++ b/core/src/test/scala/org/apache/spark/util/TimeStampedHashMapSuite.scala
@@ -171,8 +171,8 @@ class TimeStampedHashMapSuite extends SparkFunSuite {
})
test(name + " - threading safety test") {
- threads.map(_.start)
- threads.map(_.join)
+ threads.foreach(_.start())
+ threads.foreach(_.join())
assert(!error)
}
}