-
- Downloads
SPARK-1446: Spark examples should not do a System.exit
Spark examples should exit nice using SparkContext.stop() method, rather than System.exit System.exit can cause issues like in SPARK-1407 Author: Sandeep <sandeep@techaddict.me> Closes #370 from techaddict/1446 and squashes the following commits: e9234cf [Sandeep] SPARK-1446: Spark examples should not do a System.exit Spark examples should exit nice using SparkContext.stop() method, rather than System.exit System.exit can cause issues like in SPARK-1407
Showing
- examples/src/main/java/org/apache/spark/examples/JavaHdfsLR.java 1 addition, 1 deletion...s/src/main/java/org/apache/spark/examples/JavaHdfsLR.java
- examples/src/main/java/org/apache/spark/examples/JavaLogQuery.java 1 addition, 1 deletion...src/main/java/org/apache/spark/examples/JavaLogQuery.java
- examples/src/main/java/org/apache/spark/examples/JavaPageRank.java 1 addition, 1 deletion...src/main/java/org/apache/spark/examples/JavaPageRank.java
- examples/src/main/java/org/apache/spark/examples/JavaTC.java 1 addition, 1 deletionexamples/src/main/java/org/apache/spark/examples/JavaTC.java
- examples/src/main/java/org/apache/spark/examples/JavaWordCount.java 3 additions, 3 deletions...rc/main/java/org/apache/spark/examples/JavaWordCount.java
- examples/src/main/java/org/apache/spark/mllib/examples/JavaALS.java 1 addition, 1 deletion...rc/main/java/org/apache/spark/mllib/examples/JavaALS.java
- examples/src/main/java/org/apache/spark/mllib/examples/JavaKMeans.java 1 addition, 1 deletion...main/java/org/apache/spark/mllib/examples/JavaKMeans.java
- examples/src/main/java/org/apache/spark/mllib/examples/JavaLR.java 1 addition, 1 deletion...src/main/java/org/apache/spark/mllib/examples/JavaLR.java
- examples/src/main/scala/org/apache/spark/examples/BroadcastTest.scala 1 addition, 1 deletion.../main/scala/org/apache/spark/examples/BroadcastTest.scala
- examples/src/main/scala/org/apache/spark/examples/CassandraCQLTest.scala 1 addition, 1 deletion...in/scala/org/apache/spark/examples/CassandraCQLTest.scala
- examples/src/main/scala/org/apache/spark/examples/ExceptionHandlingTest.scala 1 addition, 1 deletion...ala/org/apache/spark/examples/ExceptionHandlingTest.scala
- examples/src/main/scala/org/apache/spark/examples/GroupByTest.scala 2 additions, 3 deletions...rc/main/scala/org/apache/spark/examples/GroupByTest.scala
- examples/src/main/scala/org/apache/spark/examples/HBaseTest.scala 3 additions, 3 deletions.../src/main/scala/org/apache/spark/examples/HBaseTest.scala
- examples/src/main/scala/org/apache/spark/examples/HdfsTest.scala 1 addition, 1 deletion...s/src/main/scala/org/apache/spark/examples/HdfsTest.scala
- examples/src/main/scala/org/apache/spark/examples/LocalALS.scala 1 addition, 1 deletion...s/src/main/scala/org/apache/spark/examples/LocalALS.scala
- examples/src/main/scala/org/apache/spark/examples/MultiBroadcastTest.scala 1 addition, 1 deletion.../scala/org/apache/spark/examples/MultiBroadcastTest.scala
- examples/src/main/scala/org/apache/spark/examples/SimpleSkewedGroupByTest.scala 3 additions, 4 deletions...a/org/apache/spark/examples/SimpleSkewedGroupByTest.scala
- examples/src/main/scala/org/apache/spark/examples/SkewedGroupByTest.scala 3 additions, 4 deletions...n/scala/org/apache/spark/examples/SkewedGroupByTest.scala
- examples/src/main/scala/org/apache/spark/examples/SparkALS.scala 2 additions, 2 deletions...s/src/main/scala/org/apache/spark/examples/SparkALS.scala
- examples/src/main/scala/org/apache/spark/examples/SparkHdfsLR.scala 1 addition, 1 deletion...rc/main/scala/org/apache/spark/examples/SparkHdfsLR.scala
Loading
Please register or sign in to comment