From 0815f990d32b3f6530caa9ef34f20b1686cd2de4 Mon Sep 17 00:00:00 2001
From: zhang_way <hsdcloud@163.com>
Date: Mon, 26 Jun 2017 15:31:27 +0800
Subject: [PATCH] Update StreamingLogInput.scala

---
 .../learningsparkexamples/scala/StreamingLogInput.scala       | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/main/scala/com/oreilly/learningsparkexamples/scala/StreamingLogInput.scala b/src/main/scala/com/oreilly/learningsparkexamples/scala/StreamingLogInput.scala
index 14f9b579..4ed9dc6a 100644
--- a/src/main/scala/com/oreilly/learningsparkexamples/scala/StreamingLogInput.scala
+++ b/src/main/scala/com/oreilly/learningsparkexamples/scala/StreamingLogInput.scala
@@ -18,11 +18,11 @@ object StreamingLogInput {
     val lines = ssc.socketTextStream("localhost", 7777)
     val errorLines = processLines(lines)
     // Print out the lines with errors, which causes this DStream to be evaluated
-    errorLines.print()
+    print(errorLines)
     // start our streaming context and wait for it to "finish"
     ssc.start()
     // Wait for 10 seconds then exit. To run forever call without a timeout
-    ssc.awaitTermination(10000)
+    ssc.awaitTerminationOrTimeout(10000)
     ssc.stop()
   }
   def processLines(lines: DStream[String]) = {