From 0724f444c587937045bcd3e92fd768a7fa9c3e00 Mon Sep 17 00:00:00 2001 From: timothy65535 Date: Fri, 29 Oct 2021 17:22:53 +0800 Subject: [PATCH] [KYUUBI #1310] Remove redundant store parameter ### _Why are the changes needed?_ The `store` is a member variable of `SparkSQLEngine`, we can get it from `SparkSQLEngine` directly. ### _How was this patch tested?_ - [ ] Add some test cases that check the changes thoroughly including negative and positive cases if possible - [ ] Add screenshots for manual tests if appropriate - [ ] [Run test](https://kyuubi.readthedocs.io/en/latest/develop_tools/testing.html#running-tests) locally before make a pull request Closes #1310 from timothy65535/patch. Closes #1310 1a97a1c7 [root] trigger rebuild eae0fe34 [timothy65535] Remove redundant parameter Lead-authored-by: timothy65535 Co-authored-by: root Signed-off-by: Cheng Pan --- .../scala/org/apache/kyuubi/engine/spark/SparkSQLEngine.scala | 2 +- .../src/main/scala/org/apache/spark/kyuubi/ui/EnginePage.scala | 2 +- .../scala/org/apache/spark/kyuubi/ui/EngineSessionPage.scala | 2 +- .../src/main/scala/org/apache/spark/kyuubi/ui/EngineTab.scala | 3 +-- 4 files changed, 4 insertions(+), 5 deletions(-) diff --git a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/SparkSQLEngine.scala b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/SparkSQLEngine.scala index 223e54a9a..57b4aa5d2 100644 --- a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/SparkSQLEngine.scala +++ b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/kyuubi/engine/spark/SparkSQLEngine.scala @@ -134,7 +134,7 @@ object SparkSQLEngine extends Logging { } try { engine.start() - EngineTab(engine, store) + EngineTab(engine) val event = EngineEvent(engine) info(event) EventLoggingService.onEvent(event) diff --git a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/spark/kyuubi/ui/EnginePage.scala b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/spark/kyuubi/ui/EnginePage.scala index 555c6a399..117b6b220 100644 --- a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/spark/kyuubi/ui/EnginePage.scala +++ b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/spark/kyuubi/ui/EnginePage.scala @@ -35,7 +35,7 @@ import org.apache.kyuubi.engine.spark.events.SessionEvent import org.apache.kyuubi.engine.spark.events.SparkStatementEvent case class EnginePage(parent: EngineTab) extends WebUIPage("") { - private val store = parent.store + private val store = parent.engine.store override def render(request: HttpServletRequest): Seq[Node] = { val content = diff --git a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/spark/kyuubi/ui/EngineSessionPage.scala b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/spark/kyuubi/ui/EngineSessionPage.scala index f2eaf992a..0a532a38a 100644 --- a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/spark/kyuubi/ui/EngineSessionPage.scala +++ b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/spark/kyuubi/ui/EngineSessionPage.scala @@ -30,7 +30,7 @@ import org.apache.spark.util.Utils /** Page for Spark Web UI that shows statistics of jobs running in the engine server */ case class EngineSessionPage(parent: EngineTab) extends WebUIPage("session") with Logging { - val store = parent.store + val store = parent.engine.store /** Render the page */ def render(request: HttpServletRequest): Seq[Node] = { diff --git a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/spark/kyuubi/ui/EngineTab.scala b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/spark/kyuubi/ui/EngineTab.scala index 5ccbe68d2..4feae3ab7 100644 --- a/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/spark/kyuubi/ui/EngineTab.scala +++ b/externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/spark/kyuubi/ui/EngineTab.scala @@ -25,13 +25,12 @@ import scala.util.control.NonFatal import org.apache.kyuubi.{Logging, Utils} import org.apache.kyuubi.config.KyuubiConf import org.apache.kyuubi.engine.spark.SparkSQLEngine -import org.apache.kyuubi.engine.spark.events.EngineEventsStore import org.apache.kyuubi.service.ServiceState /** * Note that [[SparkUITab]] is private for Spark */ -case class EngineTab(engine: SparkSQLEngine, store: EngineEventsStore) +case class EngineTab(engine: SparkSQLEngine) extends SparkUITab(engine.spark.sparkContext.ui.orNull, "kyuubi") with Logging { override val name: String = "Kyuubi Query Engine"