We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 35a763e commit edde03cCopy full SHA for edde03c
core/src/main/scala/org/apache/spark/ui/JettyUtils.scala
@@ -305,7 +305,9 @@ private[spark] object JettyUtils extends Logging {
305
addFilters(handlers, conf)
306
307
// Start the server first, with no connectors.
308
- val pool = new QueuedThreadPool
+ // Jetty threads count is configurable, default value is 200
309
+ val maxThreadsCount = conf.getInt("spark.history.maxJettyThreadsCount", 200)
310
+ val pool = new QueuedThreadPool(maxThreadsCount)
311
if (serverName.nonEmpty) {
312
pool.setName(serverName)
313
}
0 commit comments