You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by pw...@apache.org on 2014/06/20 06:06:35 UTC
git commit: HOTFIX: SPARK-2208 local metrics tests can fail on fast
machines
Repository: spark
Updated Branches:
refs/heads/master 5464e7917 -> e5514790d
HOTFIX: SPARK-2208 local metrics tests can fail on fast machines
Author: Patrick Wendell <pw...@gmail.com>
Closes #1141 from pwendell/hotfix and squashes the following commits:
83e4c79 [Patrick Wendell] HOTFIX: SPARK-2208 local metrics tests can fail on fast machines
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/e5514790
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/e5514790
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/e5514790
Branch: refs/heads/master
Commit: e5514790d70b35422dba2773e43e2e382548fa56
Parents: 5464e79
Author: Patrick Wendell <pw...@gmail.com>
Authored: Thu Jun 19 21:06:28 2014 -0700
Committer: Patrick Wendell <pw...@gmail.com>
Committed: Thu Jun 19 21:06:28 2014 -0700
----------------------------------------------------------------------
.../scala/org/apache/spark/scheduler/SparkListenerSuite.scala | 3 +++
1 file changed, 3 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/spark/blob/e5514790/core/src/test/scala/org/apache/spark/scheduler/SparkListenerSuite.scala
----------------------------------------------------------------------
diff --git a/core/src/test/scala/org/apache/spark/scheduler/SparkListenerSuite.scala b/core/src/test/scala/org/apache/spark/scheduler/SparkListenerSuite.scala
index be506e0..abd7b22 100644
--- a/core/src/test/scala/org/apache/spark/scheduler/SparkListenerSuite.scala
+++ b/core/src/test/scala/org/apache/spark/scheduler/SparkListenerSuite.scala
@@ -239,11 +239,14 @@ class SparkListenerSuite extends FunSuite with LocalSparkContext with Matchers
checkNonZeroAvg(
taskInfoMetrics.map(_._2.executorDeserializeTime),
stageInfo + " executorDeserializeTime")
+
+ /* Test is disabled (SEE SPARK-2208)
if (stageInfo.rddInfos.exists(_.name == d4.name)) {
checkNonZeroAvg(
taskInfoMetrics.map(_._2.shuffleReadMetrics.get.fetchWaitTime),
stageInfo + " fetchWaitTime")
}
+ */
taskInfoMetrics.foreach { case (taskInfo, taskMetrics) =>
taskMetrics.resultSize should be > (0l)