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 f35b6980e52..eaeb91bdc10 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 @@ -22,9 +22,8 @@ import java.util.concurrent.CountDownLatch import scala.util.control.NonFatal -import org.apache.spark.SparkConf +import org.apache.spark.{ui, SparkConf} import org.apache.spark.kyuubi.SparkSQLEngineListener -import org.apache.spark.kyuubi.ui.EngineTab import org.apache.spark.sql.SparkSession import org.apache.kyuubi.{KyuubiException, Logging} @@ -134,7 +133,7 @@ object SparkSQLEngine extends Logging { } try { engine.start() - EngineTab(engine) + ui.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/ui/EnginePage.scala similarity index 97% rename from externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/spark/kyuubi/ui/EnginePage.scala rename to externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/spark/ui/EnginePage.scala index 7f870ec6382..2f403236cdb 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/ui/EnginePage.scala @@ -15,7 +15,7 @@ * limitations under the License. */ -package org.apache.spark.kyuubi.ui +package org.apache.spark.ui import java.net.URLEncoder import java.nio.charset.StandardCharsets.UTF_8 @@ -26,13 +26,11 @@ import scala.collection.JavaConverters.mapAsScalaMapConverter import scala.xml.{Node, Unparsed} import org.apache.commons.text.StringEscapeUtils -import org.apache.spark.kyuubi.ui.TableSourceUtil._ -import org.apache.spark.ui.{PagedDataSource, PagedTable, UIUtils, WebUIPage} +import org.apache.spark.ui.TableSourceUtil._ import org.apache.spark.ui.UIUtils._ import org.apache.kyuubi.Utils -import org.apache.kyuubi.engine.spark.events.SessionEvent -import org.apache.kyuubi.engine.spark.events.SparkStatementEvent +import org.apache.kyuubi.engine.spark.events.{SessionEvent, SparkStatementEvent} case class EnginePage(parent: EngineTab) extends WebUIPage("") { private val store = parent.engine.store @@ -401,7 +399,7 @@ private class SessionStatsTableDataSource( case "User" => Ordering.by(_.username) case "Client IP" => Ordering.by(_.ip) case "Session ID" => Ordering.by(_.sessionId) - case "Start Time" => Ordering by (_.startTime) + case "Start Time" => Ordering.by(_.startTime) case "Finish Time" => Ordering.by(_.endTime) case "Duration" => Ordering.by(_.duration) case "Total Statements" => Ordering.by(_.totalOperations) @@ -435,7 +433,7 @@ private class StatementStatsTableDataSource( val ordering: Ordering[SparkStatementEvent] = sortColumn match { case "User" => Ordering.by(_.username) case "Statement ID" => Ordering.by(_.statementId) - case "Create Time" => Ordering by (_.createTime) + case "Create Time" => Ordering.by(_.createTime) case "Finish Time" => Ordering.by(_.completeTime) case "Duration" => Ordering.by(_.duration) case "Statement" => Ordering.by(_.statement) 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/ui/EngineSessionPage.scala similarity index 98% rename from externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/spark/kyuubi/ui/EngineSessionPage.scala rename to externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/spark/ui/EngineSessionPage.scala index 0a27d47da14..8d3e828be6d 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/ui/EngineSessionPage.scala @@ -15,7 +15,7 @@ * limitations under the License. */ -package org.apache.spark.kyuubi.ui +package org.apache.spark.ui import java.util.Date import javax.servlet.http.HttpServletRequest @@ -23,7 +23,6 @@ import javax.servlet.http.HttpServletRequest import scala.xml.Node import org.apache.spark.internal.Logging -import org.apache.spark.ui._ import org.apache.spark.ui.UIUtils._ import org.apache.spark.util.Utils 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/ui/EngineTab.scala similarity index 97% rename from externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/spark/kyuubi/ui/EngineTab.scala rename to externals/kyuubi-spark-sql-engine/src/main/scala/org/apache/spark/ui/EngineTab.scala index 147112853ec..0ebb5d11474 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/ui/EngineTab.scala @@ -15,14 +15,12 @@ * limitations under the License. */ -package org.apache.spark.kyuubi.ui +package org.apache.spark.ui import javax.servlet.http.HttpServletRequest import scala.util.control.NonFatal -import org.apache.spark.ui.SparkUITab - import org.apache.kyuubi.{Logging, Utils} import org.apache.kyuubi.config.KyuubiConf import org.apache.kyuubi.engine.spark.SparkSQLEngine diff --git a/externals/kyuubi-spark-sql-engine/src/test/scala/org/apache/spark/kyuubi/ui/EngineTabSuite.scala b/externals/kyuubi-spark-sql-engine/src/test/scala/org/apache/spark/ui/EngineTabSuite.scala similarity index 99% rename from externals/kyuubi-spark-sql-engine/src/test/scala/org/apache/spark/kyuubi/ui/EngineTabSuite.scala rename to externals/kyuubi-spark-sql-engine/src/test/scala/org/apache/spark/ui/EngineTabSuite.scala index f2ad75ef7a6..6b7f0919f8a 100644 --- a/externals/kyuubi-spark-sql-engine/src/test/scala/org/apache/spark/kyuubi/ui/EngineTabSuite.scala +++ b/externals/kyuubi-spark-sql-engine/src/test/scala/org/apache/spark/ui/EngineTabSuite.scala @@ -15,7 +15,7 @@ * limitations under the License. */ -package org.apache.spark.kyuubi.ui +package org.apache.spark.ui import org.apache.http.client.methods.HttpGet import org.apache.http.impl.client.HttpClients