-
- Downloads
Job cancellation: address Matei's code review feedback.
Showing
- core/src/main/scala/org/apache/spark/FutureAction.scala 35 additions, 43 deletionscore/src/main/scala/org/apache/spark/FutureAction.scala
- core/src/main/scala/org/apache/spark/SparkContext.scala 8 additions, 9 deletionscore/src/main/scala/org/apache/spark/SparkContext.scala
- core/src/main/scala/org/apache/spark/TaskContext.scala 6 additions, 3 deletionscore/src/main/scala/org/apache/spark/TaskContext.scala
- core/src/main/scala/org/apache/spark/executor/MesosExecutorBackend.scala 13 additions, 5 deletions...cala/org/apache/spark/executor/MesosExecutorBackend.scala
- core/src/main/scala/org/apache/spark/rdd/AsyncRDDActions.scala 5 additions, 5 deletions...src/main/scala/org/apache/spark/rdd/AsyncRDDActions.scala
- core/src/main/scala/org/apache/spark/rdd/CheckpointRDD.scala 1 addition, 1 deletioncore/src/main/scala/org/apache/spark/rdd/CheckpointRDD.scala
- core/src/main/scala/org/apache/spark/rdd/InterruptibleRDD.scala 0 additions, 36 deletions...rc/main/scala/org/apache/spark/rdd/InterruptibleRDD.scala
- core/src/main/scala/org/apache/spark/rdd/MapPartitionsWithContextRDD.scala 6 additions, 6 deletions...la/org/apache/spark/rdd/MapPartitionsWithContextRDD.scala
- core/src/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala 11 additions, 8 deletions...rc/main/scala/org/apache/spark/rdd/PairRDDFunctions.scala
- core/src/main/scala/org/apache/spark/rdd/RDD.scala 52 additions, 46 deletionscore/src/main/scala/org/apache/spark/rdd/RDD.scala
- core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala 2 additions, 2 deletions.../main/scala/org/apache/spark/scheduler/DAGScheduler.scala
- core/src/main/scala/org/apache/spark/scheduler/ResultTask.scala 20 additions, 7 deletions...rc/main/scala/org/apache/spark/scheduler/ResultTask.scala
- core/src/main/scala/org/apache/spark/scheduler/ShuffleMapTask.scala 20 additions, 8 deletions...ain/scala/org/apache/spark/scheduler/ShuffleMapTask.scala
- core/src/main/scala/org/apache/spark/scheduler/Task.scala 13 additions, 3 deletionscore/src/main/scala/org/apache/spark/scheduler/Task.scala
- core/src/test/scala/org/apache/spark/CheckpointSuite.scala 2 additions, 2 deletionscore/src/test/scala/org/apache/spark/CheckpointSuite.scala
- core/src/test/scala/org/apache/spark/JobCancellationSuite.scala 35 additions, 4 deletions...rc/test/scala/org/apache/spark/JobCancellationSuite.scala
- core/src/test/scala/org/apache/spark/rdd/AsyncRDDActionsSuite.scala 19 additions, 28 deletions...est/scala/org/apache/spark/rdd/AsyncRDDActionsSuite.scala
Loading
Please register or sign in to comment