You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2014/09/29 10:13:37 UTC
git commit: [CORE] Bugfix: LogErr format in DAGScheduler.scala
Repository: spark
Updated Branches:
refs/heads/master 1651cc117 -> 657bdff41
[CORE] Bugfix: LogErr format in DAGScheduler.scala
Author: Zhang, Liye <li...@intel.com>
Closes #2572 from liyezhang556520/DAGLogErr and squashes the following commits:
5be2491 [Zhang, Liye] Bugfix: LogErr format in DAGScheduler.scala
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/657bdff4
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/657bdff4
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/657bdff4
Branch: refs/heads/master
Commit: 657bdff41a27568a981b3e342ad380fe92aa08a0
Parents: 1651cc1
Author: Zhang, Liye <li...@intel.com>
Authored: Mon Sep 29 01:13:15 2014 -0700
Committer: Reynold Xin <rx...@apache.org>
Committed: Mon Sep 29 01:13:15 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/657bdff4/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 70c235d..5a96f52 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)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org