diff options
| author | Patrick Wendell <pwendell@gmail.com> | 2014-06-19 21:06:28 -0700 |
|---|---|---|
| committer | Patrick Wendell <pwendell@gmail.com> | 2014-06-19 21:06:28 -0700 |
| commit | e5514790d70b35422dba2773e43e2e382548fa56 (patch) | |
| tree | b568f6d871d68aa7a3da75caf186382219032fec /core/src/test | |
| parent | 5464e79175e2fc85e2cadf0dd7c9a45dad028326 (diff) | |
| download | spark-e5514790d70b35422dba2773e43e2e382548fa56.tar.gz spark-e5514790d70b35422dba2773e43e2e382548fa56.tar.bz2 spark-e5514790d70b35422dba2773e43e2e382548fa56.zip | |
HOTFIX: SPARK-2208 local metrics tests can fail on fast machines
Author: Patrick Wendell <pwendell@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
Diffstat (limited to 'core/src/test')
| -rw-r--r-- | core/src/test/scala/org/apache/spark/scheduler/SparkListenerSuite.scala | 3 |
1 files changed, 3 insertions, 0 deletions
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 be506e0287..abd7b22310 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) |