aboutsummaryrefslogtreecommitdiff
path: root/core/src/test/scala/org/apache/spark/broadcast/BroadcastSuite.scala
diff options
context:
space:
mode:
Diffstat (limited to 'core/src/test/scala/org/apache/spark/broadcast/BroadcastSuite.scala')
-rw-r--r--core/src/test/scala/org/apache/spark/broadcast/BroadcastSuite.scala2
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/test/scala/org/apache/spark/broadcast/BroadcastSuite.scala b/core/src/test/scala/org/apache/spark/broadcast/BroadcastSuite.scala
index 88fdbbdaec..f97cfbba32 100644
--- a/core/src/test/scala/org/apache/spark/broadcast/BroadcastSuite.scala
+++ b/core/src/test/scala/org/apache/spark/broadcast/BroadcastSuite.scala
@@ -37,7 +37,7 @@ class DummyBroadcastClass(rdd: RDD[Int]) extends Serializable {
rdd.map { x =>
val bm = SparkEnv.get.blockManager
// Check if broadcast block was fetched
- val isFound = bm.getLocal(BroadcastBlockId(bid)).isDefined
+ val isFound = bm.getLocalValues(BroadcastBlockId(bid)).isDefined
(x, isFound)
}.collect().toSet
}