review commit

tdas · May 14, 2014 · 4afe71d · 4afe71d
1 parent 9e4ffa7
commit 4afe71d
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala b/core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala
@@ -144,8 +144,9 @@ class CoarseGrainedSchedulerBackend(scheduler: TaskSchedulerImpl, actorSystem: A
         val ser = SparkEnv.get.closureSerializer.newInstance()
         val serializedTask = ser.serialize(task)
         if (serializedTask.limit >= akkaFrameSize - 1024) {
-          var msg = "Serialized task %s:%d were %d bytes which " +
-            "exceeds spark.akka.frameSize (%d bytes)."
+          var msg = "Serialized task %s:%d was %d bytes which " +
+            "exceeds spark.akka.frameSize (%d bytes)." +
+            "Consider using broadcast variables for large values"
           msg = msg.format(task.taskId, task.index, serializedTask.limit, akkaFrameSize)
           scheduler.error(msg)
           // TODO: Need to throw an exception?