Skip to content

Commit b857849

Browse files
committed
Style: Break long line.
1 parent ecb5690 commit b857849

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -195,7 +195,9 @@ class DAGScheduler(
195195
case Some(stage) => stage
196196
case None =>
197197
val stage =
198-
newOrUsedStage(shuffleDep.rdd, shuffleDep.rdd.partitions.size, shuffleDep, jobId, shuffleDep.rdd.creationSite)
198+
newOrUsedStage(
199+
shuffleDep.rdd, shuffleDep.rdd.partitions.size, shuffleDep, jobId,
200+
shuffleDep.rdd.creationSite)
199201
shuffleToMapStage(shuffleDep.shuffleId) = stage
200202
stage
201203
}

0 commit comments

Comments
 (0)