Github user gatorsmile commented on a diff in the pull request:
https://github.com/apache/spark/pull/18887#discussion_r137941159
--- Diff:
core/src/main/scala/org/apache/spark/deploy/history/FsHistoryProvider.scala ---
@@ -742,53 +698,146 @@ private[history] object FsHistoryProvider {
private val APPL_END_EVENT_PREFIX =
"{\"Event\":\"SparkListenerApplicationEnd\""
private val LOG_START_EVENT_PREFIX =
"{\"Event\":\"SparkListenerLogStart\""
+
+ /** Current version of the data written to the listing database. */
+ private val CURRENT_LISTING_VERSION = 1L
--- End diff --
I tried to find the definition and usage of `CURRENT_LISTING_VERSION `, but
it sounds like this is not discussed. What does this really mean? When will we
change this value? Do we have a complete story about this flag?
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
