aboutsummaryrefslogtreecommitdiff
path: root/core/src/test/scala/spark/LocalSparkContext.scala
diff options
context:
space:
mode:
Diffstat (limited to 'core/src/test/scala/spark/LocalSparkContext.scala')
-rw-r--r--core/src/test/scala/spark/LocalSparkContext.scala3
1 files changed, 2 insertions, 1 deletions
diff --git a/core/src/test/scala/spark/LocalSparkContext.scala b/core/src/test/scala/spark/LocalSparkContext.scala
index ff00dd05dd..76d5258b02 100644
--- a/core/src/test/scala/spark/LocalSparkContext.scala
+++ b/core/src/test/scala/spark/LocalSparkContext.scala
@@ -27,6 +27,7 @@ object LocalSparkContext {
sc.stop()
// To avoid Akka rebinding to the same port, since it doesn't unbind immediately on shutdown
System.clearProperty("spark.driver.port")
+ System.clearProperty("spark.hostPort")
}
/** Runs `f` by passing in `sc` and ensures that `sc` is stopped. */
@@ -38,4 +39,4 @@ object LocalSparkContext {
}
}
-} \ No newline at end of file
+}