diff options
author | Jey Kottalam <jey@cs.berkeley.edu> | 2013-03-26 18:14:04 -0700 |
---|---|---|
committer | Jey Kottalam <jey@cs.berkeley.edu> | 2013-03-28 15:08:41 -0700 |
commit | b569b3f20032cb581024f17dc0f45fbfb5f75f43 (patch) | |
tree | 49aea718bd1f46f1696c4858582ce3d7f0fa0cb8 | |
parent | bc36ee4fbbe3ad3b7e15fbdba53de42a29b81a9f (diff) | |
download | spark-b569b3f20032cb581024f17dc0f45fbfb5f75f43.tar.gz spark-b569b3f20032cb581024f17dc0f45fbfb5f75f43.tar.bz2 spark-b569b3f20032cb581024f17dc0f45fbfb5f75f43.zip |
Move streaming test initialization into 'before' blocks
-rw-r--r-- | streaming/src/test/scala/spark/streaming/BasicOperationsSuite.scala | 6 | ||||
-rw-r--r-- | streaming/src/test/scala/spark/streaming/InputStreamsSuite.scala | 6 |
2 files changed, 8 insertions, 4 deletions
diff --git a/streaming/src/test/scala/spark/streaming/BasicOperationsSuite.scala b/streaming/src/test/scala/spark/streaming/BasicOperationsSuite.scala index 8fce91853c..cf2ed8b1d4 100644 --- a/streaming/src/test/scala/spark/streaming/BasicOperationsSuite.scala +++ b/streaming/src/test/scala/spark/streaming/BasicOperationsSuite.scala @@ -6,10 +6,12 @@ import util.ManualClock class BasicOperationsSuite extends TestSuiteBase { - System.setProperty("spark.streaming.clock", "spark.streaming.util.ManualClock") - override def framework() = "BasicOperationsSuite" + before { + System.setProperty("spark.streaming.clock", "spark.streaming.util.ManualClock") + } + after { // To avoid Akka rebinding to the same port, since it doesn't unbind immediately on shutdown System.clearProperty("spark.driver.port") diff --git a/streaming/src/test/scala/spark/streaming/InputStreamsSuite.scala b/streaming/src/test/scala/spark/streaming/InputStreamsSuite.scala index 4d33857b25..67dca2ac31 100644 --- a/streaming/src/test/scala/spark/streaming/InputStreamsSuite.scala +++ b/streaming/src/test/scala/spark/streaming/InputStreamsSuite.scala @@ -30,12 +30,14 @@ import com.google.common.io.Files class InputStreamsSuite extends TestSuiteBase with BeforeAndAfter { - System.setProperty("spark.streaming.clock", "spark.streaming.util.ManualClock") - val testPort = 9999 override def checkpointDir = "checkpoint" + before { + System.setProperty("spark.streaming.clock", "spark.streaming.util.ManualClock") + } + after { // To avoid Akka rebinding to the same port, since it doesn't unbind immediately on shutdown System.clearProperty("spark.driver.port") |