diff options
| author | Matei Zaharia <root@ip-10-226-118-223.ec2.internal> | 2012-10-07 06:43:52 +0000 |
|---|---|---|
| committer | Matei Zaharia <root@ip-10-226-118-223.ec2.internal> | 2012-10-07 06:43:52 +0000 |
| commit | b2fc3dd902d12ab936cd0f51431868010e521e28 (patch) | |
| tree | 96b0220ba2f2e7db842736d29742c34ef80efdd0 /core/src/main | |
| parent | ea096f7cd5c20acfa89194db955e8f155c8e034b (diff) | |
| download | spark-b2fc3dd902d12ab936cd0f51431868010e521e28.tar.gz spark-b2fc3dd902d12ab936cd0f51431868010e521e28.tar.bz2 spark-b2fc3dd902d12ab936cd0f51431868010e521e28.zip | |
Log message
Diffstat (limited to 'core/src/main')
| -rw-r--r-- | core/src/main/scala/spark/MapOutputTracker.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/spark/MapOutputTracker.scala b/core/src/main/scala/spark/MapOutputTracker.scala index 42703126fb..45441aa5e5 100644 --- a/core/src/main/scala/spark/MapOutputTracker.scala +++ b/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 => |