aboutsummaryrefslogtreecommitdiff
path: root/bagel
diff options
context:
space:
mode:
authorMridul Muralidharan <mridul@gmail.com>2013-04-28 22:26:45 +0530
committerMridul Muralidharan <mridul@gmail.com>2013-04-28 22:26:45 +0530
commitafee9024430ef79cc0840a5e5788b60c8c53f9d2 (patch)
tree49f305108764dc00cba307f4f3d4a8774c3e2674 /bagel
parent1f20ef256715e5a84ba1661e235b6eda21a70b5b (diff)
downloadspark-afee9024430ef79cc0840a5e5788b60c8c53f9d2.tar.gz
spark-afee9024430ef79cc0840a5e5788b60c8c53f9d2.tar.bz2
spark-afee9024430ef79cc0840a5e5788b60c8c53f9d2.zip
Attempt to fix streaming test failures after yarn branch merge
Diffstat (limited to 'bagel')
-rw-r--r--bagel/src/test/scala/bagel/BagelSuite.scala1
1 files changed, 1 insertions, 0 deletions
diff --git a/bagel/src/test/scala/bagel/BagelSuite.scala b/bagel/src/test/scala/bagel/BagelSuite.scala
index 25db395c22..a09c978068 100644
--- a/bagel/src/test/scala/bagel/BagelSuite.scala
+++ b/bagel/src/test/scala/bagel/BagelSuite.scala
@@ -23,6 +23,7 @@ class BagelSuite extends FunSuite with Assertions with BeforeAndAfter with Timeo
}
// 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")
}
test("halting by voting") {