Merge pull request #547 from jey/maven-streaming-tests-initialization-fix
Move streaming test initialization into 'before' blocks
This commit is contained in:
commit
cad507adaf
|
@ -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")
|
||||
|
|
Loading…
Reference in a new issue