From b2fc3dd902d12ab936cd0f51431868010e521e28 Mon Sep 17 00:00:00 2001
From: Matei Zaharia <root@ip-10-226-118-223.ec2.internal>
Date: Sun, 7 Oct 2012 06:43:52 +0000
Subject: [PATCH] Log message
---
core/src/main/scala/spark/MapOutputTracker.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 =>
--
GitLab