From bd10eb81c98e5e9df453f721943a3e82d9f74ae4 Mon Sep 17 00:00:00 2001
From: jerryshao <sshao@hortonworks.com>
Date: Mon, 16 Nov 2015 17:02:21 -0800
Subject: [PATCH] [EXAMPLE][MINOR] Add missing awaitTermination in click stream
example
Author: jerryshao <sshao@hortonworks.com>
Closes #9730 from jerryshao/clickstream-fix.
---
.../spark/examples/streaming/clickstream/PageViewStream.scala | 4 ++--
1 file 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
--
GitLab