Skip to content

Commit 393af4c

Browse files
committed
Small improvement suggested by Andrew Or
1 parent 8045103 commit 393af4c

File tree

1 file changed

+7
-7
lines changed

1 file changed

+7
-7
lines changed

core/src/main/scala/org/apache/spark/MapOutputTracker.scala

Lines changed: 7 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -48,13 +48,13 @@ private[spark] class MapOutputTrackerMasterActor(tracker: MapOutputTrackerMaster
4848
if (serializedSize > maxAkkaFrameSize) {
4949
val msg = s"Map output statuses were $serializedSize bytes which " +
5050
s"exceeds spark.akka.frameSize ($maxAkkaFrameSize bytes)."
51-
/**
52-
* For SPARK-1244 we'll opt for just logging an error and then throwing an exception.
53-
* Note that on exception the actor will just restart. A bigger refactoring (SPARK-1239)
54-
* will utlimately remove this entire code path.
55-
*/
56-
logError(msg)
57-
throw new SparkException(msg)
51+
52+
/* For SPARK-1244 we'll opt for just logging an error and then throwing an exception.
53+
* Note that on exception the actor will just restart. A bigger refactoring (SPARK-1239)
54+
* will ultimately remove this entire code path. */
55+
val exception = new SparkException(msg)
56+
logError(msg, exception)
57+
throw exception
5858
}
5959
sender ! mapOutputStatuses
6060

0 commit comments

Comments
 (0)