Repository: spark Updated Branches: refs/heads/master 5464e7917 -> e5514790d
HOTFIX: SPARK-2208 local metrics tests can fail on fast machines Author: Patrick Wendell <pwend...@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 <pwend...@gmail.com> Authored: Thu Jun 19 21:06:28 2014 -0700 Committer: Patrick Wendell <pwend...@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)