-
- Downloads
Revert "[SPARK-2521] Broadcast RDD object (instead of sending it along with every task)."
This reverts commit 7b8cd175.
Showing
- core/src/main/scala/org/apache/spark/Dependency.scala 10 additions, 18 deletionscore/src/main/scala/org/apache/spark/Dependency.scala
- core/src/main/scala/org/apache/spark/SparkContext.scala 2 additions, 0 deletionscore/src/main/scala/org/apache/spark/SparkContext.scala
- core/src/main/scala/org/apache/spark/rdd/RDD.scala 7 additions, 23 deletionscore/src/main/scala/org/apache/spark/rdd/RDD.scala
- core/src/main/scala/org/apache/spark/rdd/RDDCheckpointData.scala 7 additions, 2 deletions...c/main/scala/org/apache/spark/rdd/RDDCheckpointData.scala
- core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala 4 additions, 0 deletions.../main/scala/org/apache/spark/scheduler/DAGScheduler.scala
- core/src/main/scala/org/apache/spark/scheduler/ResultTask.scala 97 additions, 31 deletions...rc/main/scala/org/apache/spark/scheduler/ResultTask.scala
- core/src/main/scala/org/apache/spark/scheduler/ShuffleMapTask.scala 99 additions, 26 deletions...ain/scala/org/apache/spark/scheduler/ShuffleMapTask.scala
- core/src/test/scala/org/apache/spark/ContextCleanerSuite.scala 25 additions, 37 deletions...src/test/scala/org/apache/spark/ContextCleanerSuite.scala
Loading
Please register or sign in to comment