Skip to content

Commit 1889b53

Browse files
committed
nit space
1 parent db79fdd commit 1889b53

File tree

2 files changed

+5
-0
lines changed

2 files changed

+5
-0
lines changed

core/src/main/scala/org/apache/spark/status/AppHistoryServerPlugin.scala

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,11 @@ private[spark] trait AppHistoryServerPlugin {
3131
*/
3232
def createListeners(conf: SparkConf, store: ElementTrackingStore): Seq[SparkListener]
3333

34+
/**
35+
* Initialize the listener parameters for incremental parsing of the event logs.
36+
*/
3437
def initialize(sparkListener: SparkListener, appId: String, attemptId: Option[String]): Unit = {}
38+
3539
/**
3640
* Sets up UI of this plugin to rebuild the history UI.
3741
*/

sql/hive-thriftserver/src/main/scala/org/apache/spark/sql/hive/thriftserver/ui/HiveThriftServer2HistoryServerPlugin.scala

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -34,6 +34,7 @@ class HiveThriftServer2HistoryServerPlugin extends AppHistoryServerPlugin {
3434
attemptId: Option[String]): Unit = {
3535
sparkListener.asInstanceOf[HiveThriftServer2Listener].initialize(appId, attemptId)
3636
}
37+
3738
override def setupUI(ui: SparkUI): Unit = {
3839
val store = new HiveThriftServer2AppStatusStore(ui.store.store)
3940
if (store.getSessionCount > 0) {

0 commit comments

Comments
 (0)