diff --git a/core/src/main/scala/org/apache/spark/status/api/v1/AllStagesResource.scala b/core/src/main/scala/org/apache/spark/status/api/v1/AllStagesResource.scala index 66cad59d00f37..97311b35f2431 100644 --- a/core/src/main/scala/org/apache/spark/status/api/v1/AllStagesResource.scala +++ b/core/src/main/scala/org/apache/spark/status/api/v1/AllStagesResource.scala @@ -146,7 +146,9 @@ private[v1] object AllStagesResource { ) } - def taskMetricDistributions(allTaskData: Iterable[TaskUIData], quantiles: Array[Double]): TaskMetricDistributions = { + def taskMetricDistributions( + allTaskData: Iterable[TaskUIData], + quantiles: Array[Double]): TaskMetricDistributions = { val rawMetrics = allTaskData.flatMap{_.taskMetrics}.toSeq @@ -186,7 +188,8 @@ private[v1] object AllStagesResource { }.metricOption val shuffleReadMetrics = - new MetricHelper[InternalShuffleReadMetrics, ShuffleReadMetricDistributions](_.shuffleReadMetrics) { + new MetricHelper[InternalShuffleReadMetrics, ShuffleReadMetricDistributions]( + _.shuffleReadMetrics) { def build: ShuffleReadMetricDistributions = new ShuffleReadMetricDistributions( readBytes = m(_.totalBytesRead), readRecords = m(_.recordsRead), @@ -199,7 +202,8 @@ private[v1] object AllStagesResource { }.metricOption val shuffleWriteMetrics = - new MetricHelper[InternalShuffleWriteMetrics, ShuffleWriteMetricDistributions](_.shuffleWriteMetrics) { + new MetricHelper[InternalShuffleWriteMetrics, ShuffleWriteMetricDistributions]( + _.shuffleWriteMetrics) { def build: ShuffleWriteMetricDistributions = new ShuffleWriteMetricDistributions( writeBytes = m(_.shuffleBytesWritten), writeRecords = m(_.shuffleRecordsWritten), diff --git a/core/src/main/scala/org/apache/spark/status/api/v1/OneStageResource.scala b/core/src/main/scala/org/apache/spark/status/api/v1/OneStageResource.scala index 1a84795007431..481063cea475c 100644 --- a/core/src/main/scala/org/apache/spark/status/api/v1/OneStageResource.scala +++ b/core/src/main/scala/org/apache/spark/status/api/v1/OneStageResource.scala @@ -178,7 +178,8 @@ object TaskSorting extends JerseyEnum[TaskSorting] { DecreasingRuntime ) - val alternateNames: Map[String, TaskSorting] = values.flatMap{x => x.alternateNames.map{_ -> x}}.toMap + val alternateNames: Map[String, TaskSorting] = + values.flatMap{x => x.alternateNames.map{_ -> x}}.toMap override def fromString(s: String): TaskSorting = { alternateNames.find { case (k, v) =>