diff options
| author | jerryshao <sshao@hortonworks.com> | 2015-11-16 17:02:21 -0800 |
|---|---|---|
| committer | Andrew Or <andrew@databricks.com> | 2015-11-16 17:02:21 -0800 |
| commit | bd10eb81c98e5e9df453f721943a3e82d9f74ae4 (patch) | |
| tree | 8cc2b597c3d4080d5d4f58eda949a8183ebbe23a /examples | |
| parent | 33a0ec93771ef5c3b388165b07cfab9014918d3b (diff) | |
| download | spark-bd10eb81c98e5e9df453f721943a3e82d9f74ae4.tar.gz spark-bd10eb81c98e5e9df453f721943a3e82d9f74ae4.tar.bz2 spark-bd10eb81c98e5e9df453f721943a3e82d9f74ae4.zip | |
[EXAMPLE][MINOR] Add missing awaitTermination in click stream example
Author: jerryshao <sshao@hortonworks.com>
Closes #9730 from jerryshao/clickstream-fix.
Diffstat (limited to 'examples')
| -rw-r--r-- | examples/src/main/scala/org/apache/spark/examples/streaming/clickstream/PageViewStream.scala | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/examples/src/main/scala/org/apache/spark/examples/streaming/clickstream/PageViewStream.scala b/examples/src/main/scala/org/apache/spark/examples/streaming/clickstream/PageViewStream.scala index ec7d39da8b..4ef238606f 100644 --- a/examples/src/main/scala/org/apache/spark/examples/streaming/clickstream/PageViewStream.scala +++ b/examples/src/main/scala/org/apache/spark/examples/streaming/clickstream/PageViewStream.scala @@ -18,7 +18,6 @@ // scalastyle:off println package org.apache.spark.examples.streaming.clickstream -import org.apache.spark.SparkContext._ import org.apache.spark.streaming.{Seconds, StreamingContext} import org.apache.spark.examples.streaming.StreamingExamples // scalastyle:off @@ -88,7 +87,7 @@ object PageViewStream { // An external dataset we want to join to this stream val userList = ssc.sparkContext.parallelize( - Map(1 -> "Patrick Wendell", 2->"Reynold Xin", 3->"Matei Zaharia").toSeq) + Map(1 -> "Patrick Wendell", 2 -> "Reynold Xin", 3 -> "Matei Zaharia").toSeq) metric match { case "pageCounts" => pageCounts.print() @@ -106,6 +105,7 @@ object PageViewStream { } ssc.start() + ssc.awaitTermination() } } // scalastyle:on println |