File tree Expand file tree Collapse file tree 1 file changed +2
-3
lines changed
core/src/main/scala/org/apache/spark/deploy/history Expand file tree Collapse file tree 1 file changed +2
-3
lines changed Original file line number Diff line number Diff line change @@ -256,9 +256,8 @@ private[history] class FsHistoryProvider(conf: SparkConf) extends ApplicationHis
256
256
}
257
257
try {
258
258
val appListener = new ApplicationEventListener
259
- val appCompleted = isApplicationCompleted(eventLog)
260
259
bus.addListener(appListener)
261
- bus.replay(logInput, logPath.toString, ! appCompleted )
260
+ bus.replay(logInput, logPath.toString)
262
261
new FsApplicationHistoryInfo (
263
262
logPath.getName(),
264
263
appListener.appId.getOrElse(logPath.getName()),
@@ -267,7 +266,7 @@ private[history] class FsHistoryProvider(conf: SparkConf) extends ApplicationHis
267
266
appListener.endTime.getOrElse(- 1L ),
268
267
getModificationTime(eventLog).get,
269
268
appListener.sparkUser.getOrElse(NOT_STARTED ),
270
- appCompleted )
269
+ isApplicationCompleted(eventLog) )
271
270
} finally {
272
271
logInput.close()
273
272
}
You can’t perform that action at this time.
0 commit comments