Skip to content

Commit c0edff1

Browse files
committed
style
1 parent c206fc5 commit c0edff1

File tree

1 file changed

+3
-1
lines changed

1 file changed

+3
-1
lines changed

core/src/test/scala/org/apache/spark/shuffle/ShuffleOutputCoordinatorSuite.scala

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,7 +31,9 @@ class ShuffleOutputCoordinatorSuite extends SparkFunSuite with BeforeAndAfterEac
3131
var tempDir: File = _
3232
var mapStatusFile: File = _
3333
// use the "port" as a way to distinguish mapstatuses, just for the test
34-
def mapStatus(attemptId: Int): MapStatus = MapStatus(BlockManagerId("1", "a.b.c", attemptId), Array(0L, 1L))
34+
def mapStatus(attemptId: Int): MapStatus = {
35+
MapStatus(BlockManagerId("1", "a.b.c", attemptId), Array(0L, 1L))
36+
}
3537
def ser: SerializerInstance = new JavaSerializer(new SparkConf()).newInstance()
3638

3739
override def beforeEach(): Unit = {

0 commit comments

Comments
 (0)