Removing whitespace modifications

apache · Jan 22, 2015 · 66a71cd · 66a71cd
1 parent 6b543ba
commit 66a71cd
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 5 deletions.
diff --git a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala
@@ -113,6 +113,7 @@ class DAGScheduler(
   // This is only safe because DAGScheduler runs in a single thread.
   private val closureSerializer = SparkEnv.get.closureSerializer.newInstance()
 
+
   /** If enabled, we may run certain actions like take() and first() locally. */
   private val localExecutionEnabled = sc.getConf.getBoolean("spark.localExecution.enabled", false)
 
@@ -1374,7 +1375,6 @@ private[scheduler] class DAGSchedulerEventProcessLoop(dagScheduler: DAGScheduler
 
     case ResubmitFailedStages =>
       dagScheduler.resubmitFailedStages()
-
   }
 
   override def onError(e: Throwable): Unit = {

diff --git a/core/src/main/scala/org/apache/spark/scheduler/DAGSchedulerEvent.scala b/core/src/main/scala/org/apache/spark/scheduler/DAGSchedulerEvent.scala
@@ -77,4 +77,3 @@ private[scheduler]
 case class TaskSetFailed(taskSet: TaskSet, reason: String) extends DAGSchedulerEvent
 
 private[scheduler] case object ResubmitFailedStages extends DAGSchedulerEvent
-
diff --git a/core/src/test/scala/org/apache/spark/scheduler/OutputCommitCoordinatorSuite.scala b/core/src/test/scala/org/apache/spark/scheduler/OutputCommitCoordinatorSuite.scala
@@ -32,9 +32,9 @@ import org.apache.spark.executor.{TaskMetrics}
 import org.apache.spark.rdd.FakeOutputCommitter
 
 /**
- * Unit tests for the output commit coordination functionality. Overrides the SchedulerImpl
- * to just run the tasks directly and send completion or error messages back to the
- * DAG scheduler.
+ * Unit tests for the output commit coordination functionality. Overrides the
+ * SchedulerImpl to just run the tasks directly and send completion or error
+ * messages back to the DAG scheduler.
  */
 class OutputCommitCoordinatorSuite
     extends FunSuiteLike
Original file line number	Diff line number	Diff line change
Expand Up		@@ -77,4 +77,3 @@ private[scheduler]
		case class TaskSetFailed(taskSet: TaskSet, reason: String) extends DAGSchedulerEvent

		private[scheduler] case object ResubmitFailedStages extends DAGSchedulerEvent