Fixing a scalastyle error

apache · Jan 29, 2015 · 594e41a · 594e41a
1 parent 60a47f4
commit 594e41a
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/core/src/main/scala/org/apache/spark/scheduler/OutputCommitCoordinator.scala b/core/src/main/scala/org/apache/spark/scheduler/OutputCommitCoordinator.scala
@@ -136,7 +136,8 @@ private[spark] class OutputCommitCoordinator(conf: SparkConf) extends Logging {
           case TaskCommitDenied(jobID, splitID, attemptID) =>
             logInfo(s"Task was denied committing, stage: $stage, taskId: $task, attempt: $attempt")
           case otherReason =>
-            logDebug(s"Authorized committer $attempt (stage=$stage, task=$task) failed; clearing lock")
+            logDebug(s"Authorized committer $attempt (stage=$stage, task=$task) failed;" +
+              s" clearing lock")
             authorizedCommitters.remove(task)
         }
       case None =>