add stop and reorganize import

apache · Feb 10, 2015 · 2e85cc1 · 2e85cc1
1 parent 2d1e916
commit 2e85cc1
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 6 deletions.
diff --git a/examples/src/main/java/org/apache/spark/examples/mllib/JavaLDAExample.java b/examples/src/main/java/org/apache/spark/examples/mllib/JavaLDAExample.java
@@ -71,5 +71,6 @@ public Tuple2<Long, Vector> call(Tuple2<Vector, Long> doc_id) {
       }
       System.out.println();
     }
+    sc.stop();
   }
 }
diff --git a/examples/src/main/scala/org/apache/spark/examples/mllib/LDAExample.scala b/examples/src/main/scala/org/apache/spark/examples/mllib/LDAExample.scala
@@ -21,15 +21,12 @@ import java.text.BreakIterator
 
 import scala.collection.mutable
 
-import scopt.OptionParser
-
 import org.apache.log4j.{Level, Logger}
-
-import org.apache.spark.{SparkContext, SparkConf}
 import org.apache.spark.mllib.clustering.LDA
 import org.apache.spark.mllib.linalg.{Vector, Vectors}
 import org.apache.spark.rdd.RDD
-
+import org.apache.spark.{SparkConf, SparkContext}
+import scopt.OptionParser
 
 /**
  * An example Latent Dirichlet Allocation (LDA) app. Run with
@@ -159,7 +156,7 @@ object LDAExample {
       }
       println()
     }
-
+    sc.stop()
   }
 
   /**
-Original file line number
+Diff line change
@@ Expand Up @@
           }
           System.out.println();
         }
+        sc.stop();
       }
     }