diff options
| author | Matei Zaharia <matei@eecs.berkeley.edu> | 2010-10-16 10:40:42 -0700 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2010-10-16 10:40:42 -0700 |
| commit | c21f840a802b4e6b3289d57fc85db3a74d546192 (patch) | |
| tree | 0f888e77f365583f85ea1577a051971c5a2d8724 /src | |
| parent | dbdd7682eb4efc28062733f76a2bd5d04856a142 (diff) | |
| download | spark-c21f840a802b4e6b3289d57fc85db3a74d546192.tar.gz spark-c21f840a802b4e6b3289d57fc85db3a74d546192.tar.bz2 spark-c21f840a802b4e6b3289d57fc85db3a74d546192.zip | |
Fixed some log messages
Diffstat (limited to 'src')
| -rw-r--r-- | src/scala/spark/SimpleJob.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/scala/spark/SimpleJob.scala b/src/scala/spark/SimpleJob.scala index d0abaa4b67..faf3b1c492 100644 --- a/src/scala/spark/SimpleJob.scala +++ b/src/scala/spark/SimpleJob.scala @@ -151,7 +151,7 @@ extends Job(jobId) with Logging val prefStr = if(preferred) "preferred" else "non-preferred" val message = "Starting task %d:%d as TID %s on slave %s: %s (%s)".format( - index, jobId, taskId, offer.getSlaveId, host, prefStr) + jobId, index, taskId, offer.getSlaveId, host, prefStr) logInfo(message) // Do various bookkeeping tidToIndex(taskId) = index @@ -166,7 +166,7 @@ extends Job(jobId) with Logging params.put("mem", MEM_PER_TASK.toString) val serializedTask = Utils.serialize(task) logDebug("Serialized size: " + serializedTask.size) - val taskName = "task %d:%d".format(jobId, taskId) + val taskName = "task %d:%d".format(jobId, index) return Some(new TaskDescription( taskId, offer.getSlaveId, taskName, params, serializedTask)) } |