diff --git a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala index 4a9518fff4e7b..dbccff2db17c0 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala @@ -126,6 +126,7 @@ class DAGScheduler( sc.env.mapOutputTracker.asInstanceOf[MapOutputTrackerMaster], sc.env.blockManager.master, sc.env) + logDebug("Starting DAGScheduler") } def this(sc: SparkContext) = this(sc, sc.taskScheduler) @@ -1574,7 +1575,7 @@ class DAGScheduler( } def stop() { - logInfo("Stopping DAGScheduler") + logDebug("Stopping DAGScheduler") messageScheduler.shutdownNow() eventProcessLoop.stop() taskScheduler.stop()