From 345c3f13b095c0119a73f5a5f2084a10df4093ee Mon Sep 17 00:00:00 2001 From: Ajith Date: Wed, 13 Mar 2019 09:18:14 +0530 Subject: [PATCH] refactored --- .../org/apache/spark/status/api/v1/SqlListResource.scala | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/sql/core/src/main/scala/org/apache/spark/status/api/v1/SqlListResource.scala b/sql/core/src/main/scala/org/apache/spark/status/api/v1/SqlListResource.scala index 54c2d0c8cf40b..d5e60139d84f3 100644 --- a/sql/core/src/main/scala/org/apache/spark/status/api/v1/SqlListResource.scala +++ b/sql/core/src/main/scala/org/apache/spark/status/api/v1/SqlListResource.scala @@ -29,7 +29,7 @@ import org.apache.spark.ui.UIUtils private[v1] class SqlListResource extends BaseAppResource { @GET - def sqlList(): ExecutionSummary = { + def sqlList(): Seq[ExecutionData] = { withUI { ui => val sqlStore = new SQLAppStatusStore(ui.store.store) var executions = List[ExecutionData]() @@ -66,7 +66,7 @@ private[v1] class SqlListResource extends BaseAppResource { if (executions.size > 0) { executions = executions.sortBy(x => x.id) } - new ExecutionSummary(executions) + executions } } } @@ -79,5 +79,3 @@ class ExecutionData (val id : Long, val runningJobs: Seq[Int], val successJobs: Seq[Int], val failedJobs: Seq[Int]) - -class ExecutionSummary (val sql: Seq[ExecutionData])