diff options
| author | Andrew Ash <andrew@andrewash.com> | 2016-05-03 14:54:43 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2016-05-03 14:54:43 -0700 |
| commit | dbacd99983a81d35476618be1615807ebba88f05 (patch) | |
| tree | 3f860d7c54a4ff167a061a6c70dff0ce1a961b52 | |
| parent | 028c6a5dba01e5d82c34701f40d15916c9d3e9d0 (diff) | |
| download | spark-dbacd99983a81d35476618be1615807ebba88f05.tar.gz spark-dbacd99983a81d35476618be1615807ebba88f05.tar.bz2 spark-dbacd99983a81d35476618be1615807ebba88f05.zip | |
[SPARK-15104] Fix spacing in log line
Otherwise get logs that look like this (note no space before NODE_LOCAL)
```
INFO [2016-05-03 21:18:51,477] org.apache.spark.scheduler.TaskSetManager: Starting task 0.0 in stage 101.0 (TID 7029, localhost, partition 0,NODE_LOCAL, 1894 bytes)
```
Author: Andrew Ash <andrew@andrewash.com>
Closes #12880 from ash211/patch-7.
| -rw-r--r-- | core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala b/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala index cd634bbf6f..bfa1e86749 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/TaskSetManager.scala @@ -479,7 +479,7 @@ private[spark] class TaskSetManager( // val timeTaken = clock.getTime() - startTime val taskName = s"task ${info.id} in stage ${taskSet.id}" logInfo(s"Starting $taskName (TID $taskId, $host, partition ${task.partitionId}," + - s"$taskLocality, ${serializedTask.limit} bytes)") + s" $taskLocality, ${serializedTask.limit} bytes)") sched.dagScheduler.taskStarted(task, info) return Some(new TaskDescription(taskId = taskId, attemptNumber = attemptNum, execId, |