Github user squito commented on a diff in the pull request:
https://github.com/apache/spark/pull/19679#discussion_r149277525
--- Diff:
core/src/test/scala/org/apache/spark/status/AppStatusListenerSuite.scala ---
@@ -685,12 +700,55 @@ class AppStatusListenerSuite extends SparkFunSuite
with BeforeAndAfter {
assert(exec.info.diskUsed === 0L)
}
+ // Add a block from a different RDD. Verify the executor is updated
correctly and also that
+ // the distribution data for rdd1 is up to date.
--- End diff --
you're only checking the distribution data for rdd2, right?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
