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 index 110d882f05598fad15ab28d893016b20e0a7dc4b..bc09935f93f804a9df556834fe237eb7e9821fbd 100644 --- a/core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala +++ b/core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala @@ -194,7 +194,7 @@ private[history] class FsHistoryProvider(conf: SparkConf, clock: Clock) // Validate the log directory. val path = new Path(logDir) if (!fs.exists(path)) { - var msg = s"Log directory specified does not exist: $logDir." + var msg = s"Log directory specified does not exist: $logDir" if (logDir == DEFAULT_LOG_DIR) { msg += " Did you configure the correct one through spark.history.fs.logDirectory?" }