Github user vanzin commented on a diff in the pull request:
https://github.com/apache/spark/pull/20546#discussion_r167072049
--- Diff: core/src/test/scala/org/apache/spark/DistributedSuite.scala ---
@@ -160,10 +160,6 @@ class DistributedSuite extends SparkFunSuite with
Matchers with LocalSparkContex
val data = sc.parallelize(1 to 1000, 10)
val cachedData = data.persist(storageLevel)
assert(cachedData.count === 1000)
-
assert(sc.getExecutorStorageStatus.map(_.rddBlocksById(cachedData.id).size).sum
===
--- End diff --
You could replace these with code based on `sc.statusStore`.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
