File tree Expand file tree Collapse file tree 1 file changed +4
-2
lines changed
core/src/main/scala/org/apache/spark/deploy/history Expand file tree Collapse file tree 1 file changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -74,10 +74,12 @@ class FsHistoryProvider(conf: SparkConf) extends ApplicationHistoryProvider
74
74
// Validate the log directory.
75
75
val path = new Path (logDir)
76
76
if (! fs.exists(path)) {
77
- throw new IllegalArgumentException (" Logging directory specified does not exist: %s" .format(logDir))
77
+ throw new IllegalArgumentException (
78
+ " Logging directory specified does not exist: %s" .format(logDir))
78
79
}
79
80
if (! fs.getFileStatus(path).isDir) {
80
- throw new IllegalArgumentException (" Logging directory specified is not a directory: %s" .format(logDir))
81
+ throw new IllegalArgumentException (
82
+ " Logging directory specified is not a directory: %s" .format(logDir))
81
83
}
82
84
83
85
checkForLogs()
You can’t perform that action at this time.
0 commit comments