Repository: spark Updated Branches: refs/heads/branch-1.1 004b6fa77 -> 7d88471e8
[CORE] Bugfix: LogErr format in DAGScheduler.scala Author: Zhang, Liye <[email protected]> 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 <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/7d88471e Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/7d88471e Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/7d88471e Branch: refs/heads/branch-1.1 Commit: 7d88471e894d8dd825f89a7320523a10826e741b Parents: 004b6fa Author: Zhang, Liye <[email protected]> Authored: Mon Sep 29 01:13:15 2014 -0700 Committer: Reynold Xin <[email protected]> Committed: Mon Sep 29 01:15:10 2014 -0700 ---------------------------------------------------------------------- core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/7d88471e/core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala ---------------------------------------------------------------------- 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 2ccc273..688931a 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) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
