change code style and debug info

2 files changed, 3 insertions, 6 deletions

diff --git a/core/src/main/scala/spark/scheduler/local/LocalScheduler.scala b/core/src/main/scala/spark/scheduler/local/LocalScheduler.scala
index 69dacfc2bd..93d4318b29 100644
--- a/core/src/main/scala/spark/scheduler/local/LocalScheduler.scala
+++ b/core/src/main/scala/spark/scheduler/local/LocalScheduler.scala
@@ -34,8 +34,7 @@ private[spark] class LocalActor(localScheduler: LocalScheduler, var freeCores: I
   }
 
   def launchTask(tasks : Seq[TaskDescription]) {
-    for (task <- tasks)
-    {
+    for (task <- tasks) {
       freeCores -= 1
       localScheduler.threadPool.submit(new Runnable {
         def run() {
@@ -85,8 +84,7 @@ private[spark] class LocalScheduler(threads: Int, val maxFailures: Int, val sc:
     }
     schedulableBuilder.buildPools()
 
-    localActor = env.actorSystem.actorOf(
-      Props(new LocalActor(this, threads)), "Test")
+    localActor = env.actorSystem.actorOf(Props(new LocalActor(this, threads)), "Test")
   }
 
   override def setListener(listener: TaskSchedulerListener) {
@@ -109,7 +107,7 @@ private[spark] class LocalScheduler(threads: Int, val maxFailures: Int, val sc:
       val tasks = new ArrayBuffer[TaskDescription](freeCores)
       val sortedTaskSetQueue = rootPool.getSortedTaskSetQueue()
       for (manager <- sortedTaskSetQueue) {
-        logInfo("parentName:%s,name:%s,runningTasks:%s".format(manager.parent.name, manager.name, manager.runningTasks))
+        logDebug("parentName:%s,name:%s,runningTasks:%s".format(manager.parent.name, manager.name, manager.runningTasks))
       }
 
       var launchTask = false
diff --git a/core/src/main/scala/spark/scheduler/local/LocalTaskSetManager.scala b/core/src/main/scala/spark/scheduler/local/LocalTaskSetManager.scala
index f2e07d162a..70b69bb26f 100644
--- a/core/src/main/scala/spark/scheduler/local/LocalTaskSetManager.scala
+++ b/core/src/main/scala/spark/scheduler/local/LocalTaskSetManager.scala
@@ -91,7 +91,6 @@ private[spark] class LocalTaskSetManager(sched: LocalScheduler, val taskSet: Tas
     if (availableCpus > 0 && numFinished < numTasks) {
       findTask() match {
         case Some(index) =>
-          logInfo(taskSet.tasks(index).toString)
           val taskId = sched.attemptId.getAndIncrement()
           val task = taskSet.tasks(index)
           val info = new TaskInfo(taskId, index, System.currentTimeMillis(), "local", "local:1", TaskLocality.NODE_LOCAL)