ODIn/spark-instrumented-optimizer
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Fixed some log messages

Browse source
This commit is contained in:
Matei Zaharia 2010-10-16 10:40:42 -07:00
parent dbdd7682eb
commit c21f840a80
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
src/scala/spark/SimpleJob.scala
View file

@ -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))
}