You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by pw...@apache.org on 2013/12/12 08:11:41 UTC
[10/50] git commit: Change the name of input ragument in
ClusterScheduler#initialize from context to backend.
Change the name of input ragument 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.
Project: http://git-wip-us.apache.org/repos/asf/incubator-spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-spark/commit/1cb259cb
Tree: http://git-wip-us.apache.org/repos/asf/incubator-spark/tree/1cb259cb
Diff: http://git-wip-us.apache.org/repos/asf/incubator-spark/diff/1cb259cb
Branch: refs/heads/scala-2.10
Commit: 1cb259cb577bfd3385cca6bb187d7fee18bd2c24
Parents: 5d46025
Author: Henry Saputra <he...@platfora.com>
Authored: Thu Dec 5 18:50:26 2013 -0800
Committer: Henry Saputra <he...@platfora.com>
Committed: Thu Dec 5 18:50:26 2013 -0800
----------------------------------------------------------------------
.../org/apache/spark/scheduler/cluster/ClusterScheduler.scala | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-spark/blob/1cb259cb/core/src/main/scala/org/apache/spark/scheduler/cluster/ClusterScheduler.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/org/apache/spark/scheduler/cluster/ClusterScheduler.scala b/core/src/main/scala/org/apache/spark/scheduler/cluster/ClusterScheduler.scala
index c1e65a3..f475d00 100644
--- a/core/src/main/scala/org/apache/spark/scheduler/cluster/ClusterScheduler.scala
+++ b/core/src/main/scala/org/apache/spark/scheduler/cluster/ClusterScheduler.scala
@@ -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 = {