-
- Downloads
A few small scheduler / job description changes.
1. Renamed SparkContext.addLocalProperty to setLocalProperty. And allow this function to unset a property. 2. Renamed SparkContext.setDescription to setCurrentJobDescription. 3. Throw an exception if the fair scheduler allocation file is invalid.
Showing
- core/src/main/scala/spark/SparkContext.scala 9 additions, 5 deletionscore/src/main/scala/spark/SparkContext.scala
- core/src/main/scala/spark/scheduler/cluster/SchedulableBuilder.scala 39 additions, 39 deletions...in/scala/spark/scheduler/cluster/SchedulableBuilder.scala
- core/src/main/scala/spark/ui/UIWorkloadGenerator.scala 2 additions, 2 deletionscore/src/main/scala/spark/ui/UIWorkloadGenerator.scala
- core/src/test/scala/spark/scheduler/LocalSchedulerSuite.scala 24 additions, 24 deletions.../src/test/scala/spark/scheduler/LocalSchedulerSuite.scala
Loading
Please register or sign in to comment