-
- Downloads
modify to pass job annotation by localProperties and use daeamon thread to do joblogger's work
Showing
- core/src/main/scala/spark/BlockStoreShuffleFetcher.scala 1 addition, 0 deletionscore/src/main/scala/spark/BlockStoreShuffleFetcher.scala
- core/src/main/scala/spark/RDD.scala 9 additions, 1 deletioncore/src/main/scala/spark/RDD.scala
- core/src/main/scala/spark/SparkContext.scala 4 additions, 4 deletionscore/src/main/scala/spark/SparkContext.scala
- core/src/main/scala/spark/Utils.scala 8 additions, 2 deletionscore/src/main/scala/spark/Utils.scala
- core/src/main/scala/spark/executor/Executor.scala 1 addition, 0 deletionscore/src/main/scala/spark/executor/Executor.scala
- core/src/main/scala/spark/executor/TaskMetrics.scala 11 additions, 1 deletioncore/src/main/scala/spark/executor/TaskMetrics.scala
- core/src/main/scala/spark/scheduler/DAGScheduler.scala 8 additions, 0 deletionscore/src/main/scala/spark/scheduler/DAGScheduler.scala
- core/src/main/scala/spark/scheduler/JobLogger.scala 317 additions, 0 deletionscore/src/main/scala/spark/scheduler/JobLogger.scala
- core/src/main/scala/spark/scheduler/SparkListener.scala 30 additions, 3 deletionscore/src/main/scala/spark/scheduler/SparkListener.scala
- core/src/test/scala/spark/scheduler/JobLoggerSuite.scala 105 additions, 0 deletionscore/src/test/scala/spark/scheduler/JobLoggerSuite.scala
- core/src/test/scala/spark/scheduler/SparkListenerSuite.scala 1 addition, 1 deletioncore/src/test/scala/spark/scheduler/SparkListenerSuite.scala
Loading
Please register or sign in to comment