Skip to content
Snippets Groups Projects
Commit b45352e3 authored by Kay Ousterhout's avatar Kay Ousterhout
Browse files

Clear akka frame size property in tests

parent c42f5d17
No related branches found
No related tags found
No related merge requests found
...@@ -19,17 +19,21 @@ package org.apache.spark.scheduler ...@@ -19,17 +19,21 @@ package org.apache.spark.scheduler
import scala.collection.mutable.{Buffer, HashSet} import scala.collection.mutable.{Buffer, HashSet}
import org.scalatest.{BeforeAndAfter, FunSuite} import org.scalatest.{BeforeAndAfterAll, FunSuite}
import org.scalatest.matchers.ShouldMatchers import org.scalatest.matchers.ShouldMatchers
import org.apache.spark.{LocalSparkContext, SparkContext} import org.apache.spark.{LocalSparkContext, SparkContext}
import org.apache.spark.SparkContext._ import org.apache.spark.SparkContext._
class SparkListenerSuite extends FunSuite with LocalSparkContext with ShouldMatchers class SparkListenerSuite extends FunSuite with LocalSparkContext with ShouldMatchers
with BeforeAndAfter { with BeforeAndAfterAll {
/** Length of time to wait while draining listener events. */ /** Length of time to wait while draining listener events. */
val WAIT_TIMEOUT_MILLIS = 10000 val WAIT_TIMEOUT_MILLIS = 10000
override def afterAll {
System.clearProperty("spark.akka.frameSize")
}
test("basic creation of StageInfo") { test("basic creation of StageInfo") {
sc = new SparkContext("local", "DAGSchedulerSuite") sc = new SparkContext("local", "DAGSchedulerSuite")
val listener = new SaveStageInfo val listener = new SaveStageInfo
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment