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:13:15 -0700 |
| commit | 657bdff41a27568a981b3e342ad380fe92aa08a0 (patch) | |
| tree | f85bc0626b9c521ba76e8a2f91be9980613e7883 /core | |
| parent | 1651cc117d73f0af6ec9f55b0c6c9b2bd565906c (diff) | |
| download | spark-657bdff41a27568a981b3e342ad380fe92aa08a0.tar.gz spark-657bdff41a27568a981b3e342ad380fe92aa08a0.tar.bz2 spark-657bdff41a27568a981b3e342ad380fe92aa08a0.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
Diffstat (limited to 'core')
| -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 70c235dfff..5a96f52a10 100644 --- a/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala +++ b/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala @@ -1209,7 +1209,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) |