Repository: spark
Updated Branches:
  refs/heads/branch-1.2 1b6596ebe -> f7bbe297a


[SPARK-5234][ml]examples for ml don't have sparkContext.stop

JIRA issue: https://issues.apache.org/jira/browse/SPARK-5234

simply add the call.

Author: Yuhao Yang <[email protected]>

Closes #4044 from hhbyyh/addscStop and squashes the following commits:

c1f75ac [Yuhao Yang] add SparkContext.stop to 3 ml examples

(cherry picked from commit 76389c5b99183e456ff85fd92ea68d95c4c13e82)
Signed-off-by: Xiangrui Meng <[email protected]>


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/f7bbe297
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/f7bbe297
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/f7bbe297

Branch: refs/heads/branch-1.2
Commit: f7bbe297affe1245cefddb5912a7a6fcb0755cda
Parents: 1b6596e
Author: Yuhao Yang <[email protected]>
Authored: Wed Jan 14 11:53:43 2015 -0800
Committer: Xiangrui Meng <[email protected]>
Committed: Wed Jan 14 11:55:38 2015 -0800

----------------------------------------------------------------------
 .../scala/org/apache/spark/examples/ml/CrossValidatorExample.scala | 2 ++
 .../scala/org/apache/spark/examples/ml/SimpleParamsExample.scala   | 2 ++
 .../spark/examples/ml/SimpleTextClassificationPipeline.scala       | 2 ++
 3 files changed, 6 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/spark/blob/f7bbe297/examples/src/main/scala/org/apache/spark/examples/ml/CrossValidatorExample.scala
----------------------------------------------------------------------
diff --git 
a/examples/src/main/scala/org/apache/spark/examples/ml/CrossValidatorExample.scala
 
b/examples/src/main/scala/org/apache/spark/examples/ml/CrossValidatorExample.scala
index ce6bc06..d8c7ef3 100644
--- 
a/examples/src/main/scala/org/apache/spark/examples/ml/CrossValidatorExample.scala
+++ 
b/examples/src/main/scala/org/apache/spark/examples/ml/CrossValidatorExample.scala
@@ -106,5 +106,7 @@ object CrossValidatorExample {
       .foreach { case Row(id: Long, text: String, score: Double, prediction: 
Double) =>
       println("(" + id + ", " + text + ") --> score=" + score + ", 
prediction=" + prediction)
     }
+
+    sc.stop()
   }
 }

http://git-wip-us.apache.org/repos/asf/spark/blob/f7bbe297/examples/src/main/scala/org/apache/spark/examples/ml/SimpleParamsExample.scala
----------------------------------------------------------------------
diff --git 
a/examples/src/main/scala/org/apache/spark/examples/ml/SimpleParamsExample.scala
 
b/examples/src/main/scala/org/apache/spark/examples/ml/SimpleParamsExample.scala
index 44d5b08..e8a2adf 100644
--- 
a/examples/src/main/scala/org/apache/spark/examples/ml/SimpleParamsExample.scala
+++ 
b/examples/src/main/scala/org/apache/spark/examples/ml/SimpleParamsExample.scala
@@ -97,5 +97,7 @@ object SimpleParamsExample {
       .foreach { case Row(features: Vector, label: Double, prob: Double, 
prediction: Double) =>
         println("(" + features + ", " + label + ") -> prob=" + prob + ", 
prediction=" + prediction)
       }
+
+    sc.stop()
   }
 }

http://git-wip-us.apache.org/repos/asf/spark/blob/f7bbe297/examples/src/main/scala/org/apache/spark/examples/ml/SimpleTextClassificationPipeline.scala
----------------------------------------------------------------------
diff --git 
a/examples/src/main/scala/org/apache/spark/examples/ml/SimpleTextClassificationPipeline.scala
 
b/examples/src/main/scala/org/apache/spark/examples/ml/SimpleTextClassificationPipeline.scala
index 92895a0..b9a6ef0 100644
--- 
a/examples/src/main/scala/org/apache/spark/examples/ml/SimpleTextClassificationPipeline.scala
+++ 
b/examples/src/main/scala/org/apache/spark/examples/ml/SimpleTextClassificationPipeline.scala
@@ -85,5 +85,7 @@ object SimpleTextClassificationPipeline {
       .foreach { case Row(id: Long, text: String, score: Double, prediction: 
Double) =>
         println("(" + id + ", " + text + ") --> score=" + score + ", 
prediction=" + prediction)
       }
+
+    sc.stop()
   }
 }


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to