Skip to content

Commit

Permalink
Feedback.
Browse files Browse the repository at this point in the history
  • Loading branch information
Marcelo Vanzin committed Aug 15, 2017
1 parent b696f96 commit 519dab0
Show file tree
Hide file tree
Showing 2 changed files with 9 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -56,11 +56,10 @@ import org.apache.spark.util.kvstore._
*
* - New attempts are detected in [[checkForLogs]]: the log dir is scanned, and any
* entries in the log dir whose modification time is greater than the last scan time
* are considered new or updated. These are replayed to create a new [[FsApplicationAttemptInfo]]
* entry and update or create a matching [[FsApplicationHistoryInfo]] element in the list
* of applications.
* are considered new or updated. These are replayed to create a new attempt info entry
* and update or create a matching application info element in the list of applications.
* - Updated attempts are also found in [[checkForLogs]] -- if the attempt's log file has grown, the
* [[FsApplicationAttemptInfo]] is replaced by another one with a larger log size.
* attempt is replaced by another one with a larger log size.
* - When [[updateProbe()]] is invoked to check if a loaded [[SparkUI]]
* instance is out of date, the log size of the cached instance is checked against the app last
* loaded by [[checkForLogs]].
Expand Down Expand Up @@ -137,10 +136,9 @@ private[history] class FsHistoryProvider(conf: SparkConf, clock: Clock)
val meta = db.getMetadata(classOf[KVStoreMetadata])

if (meta == null) {
db.setMetadata(new KVStoreMetadata(CURRENT_LISTING_VERSION, logDir.toString()))
db.setMetadata(new KVStoreMetadata(CURRENT_LISTING_VERSION, logDir))
db
} else if (meta.version != CURRENT_LISTING_VERSION ||
!logDir.toString().equals(meta.logDir)) {
} else if (meta.version != CURRENT_LISTING_VERSION || !logDir.equals(meta.logDir)) {
logInfo("Detected mismatched config in existing DB, deleting...")
db.close()
Utils.deleteRecursively(dbPath)
Expand Down
6 changes: 4 additions & 2 deletions docs/monitoring.md
Original file line number Diff line number Diff line change
Expand Up @@ -222,9 +222,11 @@ The history server can be configured as follows:
</tr>
<tr>
<td>spark.history.store.path</td>
<td>/var/lib/spark-history</td>
<td>(none)</td>
<td>
Local directory where history server will cache application history data.
Local directory where to cache application history data. If set, the history
server will store application data on disk instead of keeping it in memory. The data
written to disk will be re-used in the event of a history server restart.
</td>
</tr>
</table>
Expand Down

0 comments on commit 519dab0

Please sign in to comment.