This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch dev-1.1.2
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/dev-1.1.2 by this push:
new 5e1877d4b5 Add http header size parameter (#11871)
5e1877d4b5 is described below
commit 5e1877d4b5800c052d0bb6e2d29f090ccd871333
Author: jiafeng.zhang <[email protected]>
AuthorDate: Thu Aug 18 08:58:35 2022 +0800
Add http header size parameter (#11871)
Add http header size parameter
---
.../src/main/java/org/apache/doris/PaloFe.java | 3 +++
.../main/java/org/apache/doris/common/Config.java | 15 +++++++++++
.../java/org/apache/doris/httpv2/HttpServer.java | 31 ++++++++++++++++++++++
3 files changed, 49 insertions(+)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/PaloFe.java
b/fe/fe-core/src/main/java/org/apache/doris/PaloFe.java
index 2b04cbc90c..98924612dc 100755
--- a/fe/fe-core/src/main/java/org/apache/doris/PaloFe.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/PaloFe.java
@@ -143,6 +143,9 @@ public class PaloFe {
httpServer.setAcceptors(Config.jetty_server_acceptors);
httpServer.setSelectors(Config.jetty_server_selectors);
httpServer.setWorkers(Config.jetty_server_workers);
+ httpServer.setMaxThreads(Config.jetty_threadPool_maxThreads);
+ httpServer.setMinThreads(Config.jetty_threadPool_minThreads);
+
httpServer.setMaxHttpHeaderSize(Config.jetty_server_max_http_header_size);
httpServer.start(dorisHomeDir);
qeService.start();
diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/Config.java
b/fe/fe-core/src/main/java/org/apache/doris/common/Config.java
index 3a51f7d0dc..6ac8b4353d 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/common/Config.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/common/Config.java
@@ -343,11 +343,26 @@ public class Config extends ConfigBase {
@ConfField public static int jetty_server_acceptors = 2;
@ConfField public static int jetty_server_selectors = 4;
@ConfField public static int jetty_server_workers = 0;
+
+ /**
+ * Configure the default minimum and maximum number of threads for jetty.
+ * The default minimum and maximum number of threads for jetty is 10 and
the maximum is 200.
+ * If this is relatively small in a high-concurrency import scenario,
+ * users can adjust it according to their own conditions.
+ */
+ @ConfField public static int jetty_threadPool_minThreads = 20;
+ @ConfField public static int jetty_threadPool_maxThreads = 400;
+
/**
* Jetty maximum number of bytes in put or post method,default:100MB
*/
@ConfField public static int jetty_server_max_http_post_size = 100 * 1024
* 1024;
+ /**
+ * http header size configuration parameter, the default value is 10K
+ */
+ @ConfField public static int jetty_server_max_http_header_size = 10240;
+
/**
* Mini load disabled by default
*/
diff --git a/fe/fe-core/src/main/java/org/apache/doris/httpv2/HttpServer.java
b/fe/fe-core/src/main/java/org/apache/doris/httpv2/HttpServer.java
index 0904463824..bb2448c24e 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/httpv2/HttpServer.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/httpv2/HttpServer.java
@@ -41,6 +41,34 @@ public class HttpServer extends SpringBootServletInitializer
{
private int maxHttpPostSize ;
private int workers;
+ private int minThreads;
+ private int maxThreads;
+ private int maxHttpHeaderSize;
+
+ public int getMaxHttpHeaderSize() {
+ return maxHttpHeaderSize;
+ }
+
+ public void setMaxHttpHeaderSize(int maxHttpHeaderSize) {
+ this.maxHttpHeaderSize = maxHttpHeaderSize;
+ }
+
+ public int getMinThreads() {
+ return minThreads;
+ }
+
+ public void setMinThreads(int minThreads) {
+ this.minThreads = minThreads;
+ }
+
+ public int getMaxThreads() {
+ return maxThreads;
+ }
+
+ public void setMaxThreads(int maxThreads) {
+ this.maxThreads = maxThreads;
+ }
+
public void setWorkers(int workers) {
this.workers = workers;
}
@@ -78,6 +106,9 @@ public class HttpServer extends SpringBootServletInitializer
{
properties.put("server.jetty.acceptors", this.acceptors);
properties.put("server.jetty.max-http-post-size",
this.maxHttpPostSize);
properties.put("server.jetty.selectors", this.selectors);
+ properties.put("server.jetty.threadPool.maxThreads", this.maxThreads);
+ properties.put("server.jetty.threadPool.minThreads", this.minThreads);
+ properties.put("server.max-http-header-size", this.maxHttpHeaderSize);
//Worker thread pool is not set by default, set according to your needs
if(this.workers > 0) {
properties.put("server.jetty.workers", this.workers);
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
