Permalink
Browse files

Log message

  • Loading branch information...
1 parent ea096f7 commit b2fc3dd902d12ab936cd0f51431868010e521e28 Matei Zaharia committed Oct 7, 2012
Showing with 1 addition and 1 deletion.
  1. +1 −1 core/src/main/scala/spark/MapOutputTracker.scala
@@ -26,7 +26,7 @@ private[spark] case object StopMapOutputTracker extends MapOutputTrackerMessage
private[spark] class MapOutputTrackerActor(tracker: MapOutputTracker) extends Actor with Logging {
def receive = {
case GetMapOutputStatuses(shuffleId: Int, requester: String) =>
- logInfo("Asked to get map output locations for shuffle " + shuffleId + " for " + requester)
+ logInfo("Asked to send map output locations for shuffle " + shuffleId + " to " + requester)
sender ! tracker.getSerializedLocations(shuffleId)
case StopMapOutputTracker =>

0 comments on commit b2fc3dd

Please sign in to comment.