-
Notifications
You must be signed in to change notification settings - Fork 28.5k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
[SPARK-17707] [WEBUI] Web UI prevents spark-submit application to be finished #15381
Conversation
Test build #66458 has finished for PR 15381 at commit
|
@@ -90,8 +95,21 @@ public void run() { | |||
Arrays.toString(sslContextFactory.getExcludeProtocols())); | |||
sslContextFactory.setKeyStorePath(keyStorePath); | |||
sslContextFactory.setKeyStorePassword(keyStorePassword); | |||
connector = new ServerConnector(httpServer, sslContextFactory); | |||
connectionFactories = AbstractConnectionFactory.getFactories( |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This will expose both http and https, and it's a behavior change. Right?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I don't think so just because I copied it from the Jetty constructor that was already being called in this path:
/* ------------------------------------------------------------ */
/** HTTP Server Connection.
* <p>Construct a ServerConnector with a private instance of {@link HttpConnectionFactory} as the primary protocol</p>.
* @param server The {@link Server} this connector will accept connection for.
* @param sslContextFactory If non null, then a {@link SslConnectionFactory} is instantiated and prepended to the
* list of HTTP Connection Factory.
*/
public ServerConnector(
@Name("server") Server server,
@Name("sslContextFactory") SslContextFactory sslContextFactory)
{
this(server,null,null,null,-1,-1,AbstractConnectionFactory.getFactories(sslContextFactory,new HttpConnectionFactory()));
}
However if this wasn't actually the intended behavior we can change it of course.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Got it. Thanks!
LGTM. Merging to master and 2.0. |
…inished 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. Existing tests; _pending_ at least manual verification of the fix. Author: Sean Owen <sowen@cloudera.com> Closes #15381 from srowen/SPARK-17707. (cherry picked from commit cff5607) Signed-off-by: Shixiong Zhu <shixiong@databricks.com>
FYI, I fixed import conflicts in JettyUtils manually for branch-2.0. |
…inished 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. Existing tests; _pending_ at least manual verification of the fix. Author: Sean Owen <sowen@cloudera.com> Closes apache#15381 from srowen/SPARK-17707.
Thanks for fixing this issue. It works in 2.0.2 now. |
…inished ## 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 apache#15381 from srowen/SPARK-17707.
What changes were proposed in this pull request?
This expands calls to Jetty's simple
ServerConnector
constructor to explicitly specify aScheduledExecutorScheduler
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.