aboutsummaryrefslogtreecommitdiff
path: root/examples
diff options
context:
space:
mode:
authorKan Zhang <kzhang@apache.org>2014-04-09 15:24:33 -0700
committerPatrick Wendell <pwendell@gmail.com>2014-04-09 15:25:29 -0700
commiteb5f2b64230faa69a53815cb61bcc87aeb233d20 (patch)
treec9b18d1b09d10a2d893c421e9b4ee79afb768b55 /examples
parentbde9cc11fee42a0a41ec52d5dc7fa0502ce94f77 (diff)
downloadspark-eb5f2b64230faa69a53815cb61bcc87aeb233d20.tar.gz
spark-eb5f2b64230faa69a53815cb61bcc87aeb233d20.tar.bz2
spark-eb5f2b64230faa69a53815cb61bcc87aeb233d20.zip
SPARK-1407 drain event queue before stopping event logger
Author: Kan Zhang <kzhang@apache.org> Closes #366 from kanzhang/SPARK-1407 and squashes the following commits: cd0629f [Kan Zhang] code refactoring and adding test b073ee6 [Kan Zhang] SPARK-1407 drain event queue before stopping event logger
Diffstat (limited to 'examples')
-rw-r--r--examples/src/main/scala/org/apache/spark/examples/SparkHdfsLR.scala2
1 files changed, 1 insertions, 1 deletions
diff --git a/examples/src/main/scala/org/apache/spark/examples/SparkHdfsLR.scala b/examples/src/main/scala/org/apache/spark/examples/SparkHdfsLR.scala
index e698b9bf37..038afbcba8 100644
--- a/examples/src/main/scala/org/apache/spark/examples/SparkHdfsLR.scala
+++ b/examples/src/main/scala/org/apache/spark/examples/SparkHdfsLR.scala
@@ -73,6 +73,6 @@ object SparkHdfsLR {
}
println("Final w: " + w)
- System.exit(0)
+ sc.stop()
}
}