diff options
author | Kay Ousterhout <kayousterhout@gmail.com> | 2013-10-23 18:23:28 -0700 |
---|---|---|
committer | Kay Ousterhout <kayousterhout@gmail.com> | 2013-10-23 18:23:28 -0700 |
commit | b45352e3737183d20a0bb69d680000a26647f024 (patch) | |
tree | 90c28d851f2fd38c90b395e6098bd2c87ca0f7f1 | |
parent | c42f5d17878974bc639bbe17724aca60e5648f0c (diff) | |
download | spark-b45352e3737183d20a0bb69d680000a26647f024.tar.gz spark-b45352e3737183d20a0bb69d680000a26647f024.tar.bz2 spark-b45352e3737183d20a0bb69d680000a26647f024.zip |
Clear akka frame size property in tests
-rw-r--r-- | core/src/test/scala/org/apache/spark/scheduler/SparkListenerSuite.scala | 8 |
1 files changed, 6 insertions, 2 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 a8e2a94ddc..f7f599532a 100644 --- a/core/src/test/scala/org/apache/spark/scheduler/SparkListenerSuite.scala +++ b/core/src/test/scala/org/apache/spark/scheduler/SparkListenerSuite.scala @@ -19,17 +19,21 @@ package org.apache.spark.scheduler import scala.collection.mutable.{Buffer, HashSet} -import org.scalatest.{BeforeAndAfter, FunSuite} +import org.scalatest.{BeforeAndAfterAll, FunSuite} import org.scalatest.matchers.ShouldMatchers import org.apache.spark.{LocalSparkContext, SparkContext} import org.apache.spark.SparkContext._ class SparkListenerSuite extends FunSuite with LocalSparkContext with ShouldMatchers - with BeforeAndAfter { + with BeforeAndAfterAll { /** Length of time to wait while draining listener events. */ val WAIT_TIMEOUT_MILLIS = 10000 + override def afterAll { + System.clearProperty("spark.akka.frameSize") + } + test("basic creation of StageInfo") { sc = new SparkContext("local", "DAGSchedulerSuite") val listener = new SaveStageInfo |