diff options
| author | Zhang, Liye <liye.zhang@intel.com> | 2014-09-29 01:13:15 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@apache.org> | 2014-09-29 01:15:10 -0700 |
| commit | 7d88471e894d8dd825f89a7320523a10826e741b (patch) | |
| tree | b6aad17122793260730a1adfd6d9403662481047 /core/src/main | |
| parent | 004b6fa77cf4eee92c35dae53bfe1c1a37210a67 (diff) | |
| download | spark-7d88471e894d8dd825f89a7320523a10826e741b.tar.gz spark-7d88471e894d8dd825f89a7320523a10826e741b.tar.bz2 spark-7d88471e894d8dd825f89a7320523a10826e741b.zip | |
[CORE] Bugfix: LogErr format in DAGScheduler.scala
Author: Zhang, Liye <liye.zhang@intel.com>
Closes #2572 from liyezhang556520/DAGLogErr and squashes the following commits:
5be2491 [Zhang, Liye] Bugfix: LogErr format in DAGScheduler.scala
(cherry picked from commit 657bdff41a27568a981b3e342ad380fe92aa08a0)
Signed-off-by: Reynold Xin <rxin@apache.org>
Diffstat (limited to 'core/src/main')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala index 2ccc27324a..688931aa4e 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala @@ -1202,7 +1202,7 @@ class DAGScheduler( .format(job.jobId, stageId)) } else if (jobsForStage.get.size == 1) { if (!stageIdToStage.contains(stageId)) { - logError("Missing Stage for stage with id $stageId") + logError(s"Missing Stage for stage with id $stageId") } else { // This is the only job that uses this stage, so fail the stage if it is running. val stage = stageIdToStage(stageId) |