-
- Downloads
Merge pull request #462 from squito/stageInfo
Track assorted metrics for each task, report summaries to user at stage completion
No related branches found
No related tags found
Showing
- core/src/main/scala/spark/BlockStoreShuffleFetcher.scala 21 additions, 5 deletionscore/src/main/scala/spark/BlockStoreShuffleFetcher.scala
- core/src/main/scala/spark/ShuffleFetcher.scala 3 additions, 1 deletioncore/src/main/scala/spark/ShuffleFetcher.scala
- core/src/main/scala/spark/SparkContext.scala 17 additions, 14 deletionscore/src/main/scala/spark/SparkContext.scala
- core/src/main/scala/spark/TaskContext.scala 7 additions, 2 deletionscore/src/main/scala/spark/TaskContext.scala
- core/src/main/scala/spark/executor/Executor.scala 11 additions, 1 deletioncore/src/main/scala/spark/executor/Executor.scala
- core/src/main/scala/spark/executor/TaskMetrics.scala 71 additions, 0 deletionscore/src/main/scala/spark/executor/TaskMetrics.scala
- core/src/main/scala/spark/rdd/CoGroupedRDD.scala 2 additions, 1 deletioncore/src/main/scala/spark/rdd/CoGroupedRDD.scala
- core/src/main/scala/spark/rdd/ShuffledRDD.scala 1 addition, 1 deletioncore/src/main/scala/spark/rdd/ShuffledRDD.scala
- core/src/main/scala/spark/rdd/SubtractedRDD.scala 1 addition, 1 deletioncore/src/main/scala/spark/rdd/SubtractedRDD.scala
- core/src/main/scala/spark/scheduler/DAGScheduler.scala 16 additions, 8 deletionscore/src/main/scala/spark/scheduler/DAGScheduler.scala
- core/src/main/scala/spark/scheduler/DAGSchedulerEvent.scala 5 additions, 1 deletioncore/src/main/scala/spark/scheduler/DAGSchedulerEvent.scala
- core/src/main/scala/spark/scheduler/ResultTask.scala 1 addition, 0 deletionscore/src/main/scala/spark/scheduler/ResultTask.scala
- core/src/main/scala/spark/scheduler/ShuffleMapTask.scala 8 additions, 0 deletionscore/src/main/scala/spark/scheduler/ShuffleMapTask.scala
- core/src/main/scala/spark/scheduler/SparkListener.scala 146 additions, 0 deletionscore/src/main/scala/spark/scheduler/SparkListener.scala
- core/src/main/scala/spark/scheduler/StageInfo.scala 12 additions, 0 deletionscore/src/main/scala/spark/scheduler/StageInfo.scala
- core/src/main/scala/spark/scheduler/Task.scala 5 additions, 2 deletionscore/src/main/scala/spark/scheduler/Task.scala
- core/src/main/scala/spark/scheduler/TaskResult.scala 5 additions, 2 deletionscore/src/main/scala/spark/scheduler/TaskResult.scala
- core/src/main/scala/spark/scheduler/TaskSchedulerListener.scala 4 additions, 1 deletion...rc/main/scala/spark/scheduler/TaskSchedulerListener.scala
- core/src/main/scala/spark/scheduler/cluster/TaskInfo.scala 2 additions, 1 deletioncore/src/main/scala/spark/scheduler/cluster/TaskInfo.scala
- core/src/main/scala/spark/scheduler/cluster/TaskSetManager.scala 5 additions, 4 deletions...c/main/scala/spark/scheduler/cluster/TaskSetManager.scala
Loading
Please register or sign in to comment