Skip to content
Snippets Groups Projects
Commit bfa68609 authored by Matei Zaharia's avatar Matei Zaharia
Browse files

Merge pull request #233 from hsaputra/changecontexttobackend

Change the name of input argument in ClusterScheduler#initialize from context to backend.

The SchedulerBackend used to be called ClusterSchedulerContext so just want to make small
change of the input param in the ClusterScheduler#initialize to reflect this.
parents 3fb302c0 1cb259cb
No related branches found
No related tags found
No related merge requests found
......@@ -100,8 +100,8 @@ private[spark] class ClusterScheduler(val sc: SparkContext)
this.dagScheduler = dagScheduler
}
def initialize(context: SchedulerBackend) {
backend = context
def initialize(backend: SchedulerBackend) {
this.backend = backend
// temporarily set rootPool name to empty
rootPool = new Pool("", schedulingMode, 0, 0)
schedulableBuilder = {
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment