SPARKC-247: Protect against null SparkContexts

CheckpointStreamSpec uses the ApacheSpark Test code base which ocassionally nulls out the Spark Context. This forces the context to be recreated after the Spark tests null it out.
datastax · Oct 5, 2015 · d977762 · d977762
1 parent db8d1b0
commit d977762
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...-connector/src/it/scala/com/datastax/spark/connector/streaming/CheckpointStreamSpec.scala b/...-connector/src/it/scala/com/datastax/spark/connector/streaming/CheckpointStreamSpec.scala
@@ -49,6 +49,8 @@ class CheckpointStreamSpec
   }
 
   override def afterAll(): Unit ={
+    //Force the recreation of the template Spark Context
+    useSparkConf(sc.getConf, true)
   }
 
   "Spark Streaming + Checkpointing" should "work with JWCTable and RPCassandra Replica" in {