Skip to content
Snippets Groups Projects
Commit b569b3f2 authored by Jey Kottalam's avatar Jey Kottalam
Browse files

Move streaming test initialization into 'before' blocks

parent bc36ee4f
No related branches found
No related tags found
No related merge requests found
......@@ -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")
......
......@@ -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")
......
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