aboutsummaryrefslogtreecommitdiff
path: root/docs/quick-start.md
diff options
context:
space:
mode:
authorSean Owen <sowen@cloudera.com>2016-10-07 10:31:41 -0700
committerShixiong Zhu <shixiong@databricks.com>2016-10-07 10:31:41 -0700
commitcff560755244dd4ccb998e0c56e81d2620cd4cff (patch)
tree3ceda00ee96a9c7717f88d6243e75be4b2076834 /docs/quick-start.md
parentdd16b52cf785ae06026bd00e8e6bedfffa791f5d (diff)
downloadspark-cff560755244dd4ccb998e0c56e81d2620cd4cff.tar.gz
spark-cff560755244dd4ccb998e0c56e81d2620cd4cff.tar.bz2
spark-cff560755244dd4ccb998e0c56e81d2620cd4cff.zip
[SPARK-17707][WEBUI] Web UI prevents spark-submit application to be finished
## What changes were proposed in this pull request? This expands calls to Jetty's simple `ServerConnector` constructor to explicitly specify a `ScheduledExecutorScheduler` that makes daemon threads. It should otherwise result in exactly the same configuration, because the other args are copied from the constructor that is currently called. (I'm not sure we should change the Hive Thriftserver impl, but I did anyway.) This also adds `sc.stop()` to the quick start guide example. ## How was this patch tested? Existing tests; _pending_ at least manual verification of the fix. Author: Sean Owen <sowen@cloudera.com> Closes #15381 from srowen/SPARK-17707.
Diffstat (limited to 'docs/quick-start.md')
-rw-r--r--docs/quick-start.md7
1 files changed, 6 insertions, 1 deletions
diff --git a/docs/quick-start.md b/docs/quick-start.md
index 2eab8d19aa..cb9a378199 100644
--- a/docs/quick-start.md
+++ b/docs/quick-start.md
@@ -240,7 +240,8 @@ object SimpleApp {
val logData = sc.textFile(logFile, 2).cache()
val numAs = logData.filter(line => line.contains("a")).count()
val numBs = logData.filter(line => line.contains("b")).count()
- println("Lines with a: %s, Lines with b: %s".format(numAs, numBs))
+ println(s"Lines with a: $numAs, Lines with b: $numBs")
+ sc.stop()
}
}
{% endhighlight %}
@@ -328,6 +329,8 @@ public class SimpleApp {
}).count();
System.out.println("Lines with a: " + numAs + ", lines with b: " + numBs);
+
+ sc.stop()
}
}
{% endhighlight %}
@@ -407,6 +410,8 @@ numAs = logData.filter(lambda s: 'a' in s).count()
numBs = logData.filter(lambda s: 'b' in s).count()
print("Lines with a: %i, lines with b: %i" % (numAs, numBs))
+
+sc.stop()
{% endhighlight %}