aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--sql/core/src/main/scala/org/apache/spark/sql/ui/AllExecutionsPage.scala2
-rw-r--r--sql/core/src/main/scala/org/apache/spark/sql/ui/SQLTab.scala12
2 files changed, 11 insertions, 3 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/ui/AllExecutionsPage.scala b/sql/core/src/main/scala/org/apache/spark/sql/ui/AllExecutionsPage.scala
index 727fc4b37f..cb7ca60b2f 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/ui/AllExecutionsPage.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/ui/AllExecutionsPage.scala
@@ -178,7 +178,7 @@ private[ui] abstract class ExecutionTable(
"%s/jobs/job?id=%s".format(UIUtils.prependBaseUri(parent.basePath), jobId)
private def executionURL(executionID: Long): String =
- "%s/sql/execution?id=%s".format(UIUtils.prependBaseUri(parent.basePath), executionID)
+ s"${UIUtils.prependBaseUri(parent.basePath)}/${parent.prefix}/execution?id=$executionID"
}
private[ui] class RunningExecutionTable(
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/ui/SQLTab.scala b/sql/core/src/main/scala/org/apache/spark/sql/ui/SQLTab.scala
index a9e5226303..3bba0afaf1 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/ui/SQLTab.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/ui/SQLTab.scala
@@ -17,13 +17,14 @@
package org.apache.spark.sql.ui
+import java.util.concurrent.atomic.AtomicInteger
+
import org.apache.spark.Logging
import org.apache.spark.sql.SQLContext
import org.apache.spark.ui.{SparkUI, SparkUITab}
private[sql] class SQLTab(sqlContext: SQLContext, sparkUI: SparkUI)
- extends SparkUITab(sparkUI, "sql") with Logging {
-
+ extends SparkUITab(sparkUI, SQLTab.nextTabName) with Logging {
val parent = sparkUI
val listener = sqlContext.listener
@@ -38,4 +39,11 @@ private[sql] class SQLTab(sqlContext: SQLContext, sparkUI: SparkUI)
private[sql] object SQLTab {
private val STATIC_RESOURCE_DIR = "org/apache/spark/sql/ui/static"
+
+ private val nextTabId = new AtomicInteger(0)
+
+ private def nextTabName: String = {
+ val nextId = nextTabId.getAndIncrement()
+ if (nextId == 0) "SQL" else s"SQL${nextId}"
+ }
}