Skip to content

Commit 719f19d

Browse files
committed
Style fixes
1 parent bb6ec62 commit 719f19d

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

core/src/main/scala/org/apache/spark/executor/TaskMetrics.scala

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -99,7 +99,7 @@ private[spark] object TaskMetrics {
9999
* from a remote block manager (which may have stored the data on-disk or in-memory).
100100
*/
101101
@DeveloperApi
102-
private[spark] object DataReadMethod extends Enumeration with Serializable {
102+
object DataReadMethod extends Enumeration with Serializable {
103103
type DataReadMethod = Value
104104
val Memory, Disk, Hadoop, Network = Value
105105
}

core/src/main/scala/org/apache/spark/ui/jobs/StagePage.scala

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -225,10 +225,10 @@ private[ui] class StagePage(parent: JobProgressTab) extends WebUIPage("stage") {
225225
}
226226

227227
def taskRow(
228-
hasInput: Boolean,
229-
hasShuffleRead: Boolean,
230-
hasShuffleWrite: Boolean,
231-
hasBytesSpilled: Boolean)(taskData: TaskUIData): Seq[Node] = {
228+
hasInput: Boolean,
229+
hasShuffleRead: Boolean,
230+
hasShuffleWrite: Boolean,
231+
hasBytesSpilled: Boolean)(taskData: TaskUIData): Seq[Node] = {
232232
taskData match { case TaskUIData(info, metrics, errorMessage) =>
233233
val duration = if (info.status == "RUNNING") info.timeRunning(System.currentTimeMillis())
234234
else metrics.map(_.executorRunTime).getOrElse(1L)

0 commit comments

Comments
 (0)