Skip to content

Commit f4a16a5

Browse files
committed
update
1 parent 73ebfe2 commit f4a16a5

File tree

3 files changed

+11
-4
lines changed

3 files changed

+11
-4
lines changed
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
org.apache.spark.sql.hive.thriftserver.ThriftServerHistoryServerPlugin
1+
org.apache.spark.sql.hive.thriftserver.HiveThriftServer2HistoryServerPlugin
Lines changed: 2 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -18,21 +18,20 @@
1818
package org.apache.spark.sql.hive.thriftserver
1919

2020
import org.apache.spark.SparkConf
21-
import org.apache.spark.internal.Logging
2221
import org.apache.spark.scheduler.SparkListener
2322
import org.apache.spark.sql.hive.thriftserver.ui.{HiveThriftServer2AppStatusStore, ThriftServerTab}
2423
import org.apache.spark.status.{AppHistoryServerPlugin, ElementTrackingStore}
2524
import org.apache.spark.ui.SparkUI
2625

27-
class ThriftServerHistoryServerPlugin extends AppHistoryServerPlugin with Logging {
26+
class HiveThriftServer2HistoryServerPlugin extends AppHistoryServerPlugin {
2827

2928
override def createListeners(conf: SparkConf, store: ElementTrackingStore): Seq[SparkListener] = {
3029
Seq(new HiveThriftServer2Listener(store, None, None, Some(conf), false))
3130
}
3231

3332
override def setupUI(ui: SparkUI): Unit = {
3433
val store = new HiveThriftServer2AppStatusStore(ui.store.store)
35-
if (store.getSessionList.nonEmpty) {
34+
if (store.getExecutionCount() > 0) {
3635
new ThriftServerTab(store, ui)
3736
}
3837
}

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

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -66,6 +66,14 @@ class HiveThriftServer2AppStatusStore(
6666
execInfo.state == ExecutionState.CANCELED ||
6767
execInfo.state == ExecutionState.CLOSED)
6868
}
69+
70+
def getSessionCount(): Long = {
71+
store.count(classOf[SessionInfo])
72+
}
73+
74+
def getExecutionCount(): Long = {
75+
store.count(classOf[ExecutionInfo])
76+
}
6977
}
7078

7179
private[thriftserver] class SessionInfo(

0 commit comments

Comments
 (0)