diff options
| author | Matei Zaharia <matei@eecs.berkeley.edu> | 2012-08-23 20:24:38 -0700 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2012-08-23 20:31:49 -0700 |
| commit | deedb9e7b722d9fb37c89d3ef82b6bb2d470dcbe (patch) | |
| tree | f09b629c4f5525ba655d1734d1b19560e0a2128b /bagel | |
| parent | 59b831b9d1161a1c2d4312bb6711d8694983b5d6 (diff) | |
| download | spark-deedb9e7b722d9fb37c89d3ef82b6bb2d470dcbe.tar.gz spark-deedb9e7b722d9fb37c89d3ef82b6bb2d470dcbe.tar.bz2 spark-deedb9e7b722d9fb37c89d3ef82b6bb2d470dcbe.zip | |
Fix further issues with tests and broadcast.
The broadcast fix is to store values as MEMORY_ONLY_DESER instead of
MEMORY_ONLY, which will save substantial time on serialization.
Diffstat (limited to 'bagel')
| -rw-r--r-- | bagel/src/test/scala/bagel/BagelSuite.scala | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/bagel/src/test/scala/bagel/BagelSuite.scala b/bagel/src/test/scala/bagel/BagelSuite.scala index d2189169d2..3da7152a09 100644 --- a/bagel/src/test/scala/bagel/BagelSuite.scala +++ b/bagel/src/test/scala/bagel/BagelSuite.scala @@ -18,7 +18,10 @@ class BagelSuite extends FunSuite with Assertions with BeforeAndAfter { var sc: SparkContext = _ after { - sc.stop() + if (sc != null) { + sc.stop() + sc = null + } } test("halting by voting") { |