diff options
author | Kan Zhang <kzhang@apache.org> | 2014-04-09 15:24:33 -0700 |
---|---|---|
committer | Patrick Wendell <pwendell@gmail.com> | 2014-04-09 15:25:29 -0700 |
commit | eb5f2b64230faa69a53815cb61bcc87aeb233d20 (patch) | |
tree | c9b18d1b09d10a2d893c421e9b4ee79afb768b55 /examples/src/main/scala | |
parent | bde9cc11fee42a0a41ec52d5dc7fa0502ce94f77 (diff) | |
download | spark-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/src/main/scala')
-rw-r--r-- | examples/src/main/scala/org/apache/spark/examples/SparkHdfsLR.scala | 2 |
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() } } |