diff options
author | Mridul Muralidharan <mridul@gmail.com> | 2013-04-28 22:26:45 +0530 |
---|---|---|
committer | Mridul Muralidharan <mridul@gmail.com> | 2013-04-28 22:26:45 +0530 |
commit | afee9024430ef79cc0840a5e5788b60c8c53f9d2 (patch) | |
tree | 49f305108764dc00cba307f4f3d4a8774c3e2674 /core | |
parent | 1f20ef256715e5a84ba1661e235b6eda21a70b5b (diff) | |
download | spark-afee9024430ef79cc0840a5e5788b60c8c53f9d2.tar.gz spark-afee9024430ef79cc0840a5e5788b60c8c53f9d2.tar.bz2 spark-afee9024430ef79cc0840a5e5788b60c8c53f9d2.zip |
Attempt to fix streaming test failures after yarn branch merge
Diffstat (limited to 'core')
-rw-r--r-- | core/src/test/scala/spark/LocalSparkContext.scala | 3 |
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 +} |