File tree Expand file tree Collapse file tree 1 file changed +3
-9
lines changed
core/src/main/scala/org/apache/spark/deploy/history Expand file tree Collapse file tree 1 file changed +3
-9
lines changed Original file line number Diff line number Diff line change @@ -103,15 +103,9 @@ class FsHistoryProvider(conf: SparkConf) extends ApplicationHistoryProvider
103103 }
104104
105105 /**
106- * Check for any updates to event logs in the base directory. This is only effective once
107- * the server has been bound.
108- *
109- * If a new completed application is found, the server renders the associated SparkUI
110- * from the application's event logs, attaches this UI to itself, and stores metadata
111- * information for this application.
112- *
113- * If the logs for an existing completed application are no longer found, the server
114- * removes all associated information and detaches the SparkUI.
106+ * Builds the application list based on the current contents of the log directory.
107+ * Tries to reuse as much of the data already in memory as possible, but not reading
108+ * applications that hasn't been updated since last time the logs were checked.
115109 */
116110 def checkForLogs () = synchronized {
117111 lastLogCheckTime = System .currentTimeMillis
You can’t perform that action at this time.
0 commit comments