Remove close() for streaming.

examples/src/main/java/org/apache/spark/examples/streaming/JavaActorWordCount.java

@@ -140,6 +140,5 @@ public Integer call(Integer i1, Integer i2) {
 
     jssc.start();
     jssc.awaitTermination();
-    jssc.close();
   }
 }

examples/src/main/java/org/apache/spark/examples/streaming/JavaCustomReceiver.java

@@ -94,7 +94,6 @@ public Integer call(Integer i1, Integer i2) {
     wordCounts.print();
     ssc.start();
     ssc.awaitTermination();
-    ssc.close();
   }
 
   // ============= Receiver code that receives data over a socket ==============

examples/src/main/java/org/apache/spark/examples/streaming/JavaDirectKafkaWordCount.java

@@ -109,6 +109,5 @@ public Integer call(Integer i1, Integer i2) {
     // Start the computation
     jssc.start();
     jssc.awaitTermination();
-    jssc.close();
   }
 }

examples/src/main/java/org/apache/spark/examples/streaming/JavaFlumeEventCount.java

@@ -71,6 +71,5 @@ public String call(Long in) {
 
     ssc.start();
     ssc.awaitTermination();
-    ssc.close();
   }
 }

examples/src/main/java/org/apache/spark/examples/streaming/JavaKafkaWordCount.java

@@ -108,6 +108,5 @@ public Integer call(Integer i1, Integer i2) {
     wordCounts.print();
     jssc.start();
     jssc.awaitTermination();
-    jssc.close();
   }
 }

examples/src/main/java/org/apache/spark/examples/streaming/JavaQueueStream.java

@@ -82,6 +82,5 @@ public Integer call(Integer i1, Integer i2) {
     reducedStream.print();
     ssc.start();
     ssc.awaitTermination();
-    ssc.close();
   }
 }

examples/src/main/java/org/apache/spark/examples/streaming/JavaRecoverableNetworkWordCount.java

@@ -213,6 +213,5 @@ public JavaStreamingContext call() {
     JavaStreamingContext ssc = JavaStreamingContext.getOrCreate(checkpointDirectory, createContextFunc);
     ssc.start();
     ssc.awaitTermination();
-    ssc.close();
   }
 }

examples/src/main/java/org/apache/spark/examples/streaming/JavaSqlNetworkWordCount.java

@@ -107,7 +107,6 @@ public JavaRecord call(String word) {
 
     ssc.start();
     ssc.awaitTermination();
-    ssc.close();
   }
 }
 

examples/src/main/java/org/apache/spark/examples/streaming/JavaStatefulNetworkWordCount.java

@@ -106,6 +106,5 @@ public Tuple2<String, Integer> call(String word, Optional<Integer> one, State<In
     stateDstream.print();
     ssc.start();
     ssc.awaitTermination();
-    ssc.close();
   }
 }

examples/src/main/java/org/apache/spark/examples/streaming/JavaTwitterHashTagJoinSentiments.java

@@ -171,6 +171,5 @@ public void call(JavaPairRDD<Double, String> happinessTopicPairs) {
 
     jssc.start();
     jssc.awaitTermination();
-    jssc.close();
   }
 }