Update code style

vanzin · Jun 15, 2015 · 3e46b35 · 3e46b35
1 parent 90f5dde
commit 3e46b35
Showing 1 changed file with 3 additions and 5 deletions.
diff --git a/core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala b/core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala
@@ -282,11 +282,9 @@ private[history] class FsHistoryProvider(conf: SparkConf, clock: Clock)
     val newAttempts = logs.flatMap { fileStatus =>
       try {
         val res = replay(fileStatus, bus)
-        res.map { r =>
-          logInfo(s"Application log ${r.logPath} loaded successfully.")
-        }.getOrElse {
-          logInfo(
-            s"Failed to load application log ${fileStatus.getPath}." +
+        res match {
+          case Some(r) => logInfo(s"Application log ${r.logPath} loaded successfully.")
+          case None => logWarning(s"Failed to load application log ${fileStatus.getPath}." +
             "The application may have not started.")
         }
         res