This is an automated email from the ASF dual-hosted git repository.
yunhong pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git
The following commit(s) were added to refs/heads/main by this push:
new ab841ba2e [client] Change the default value of
'netty.client.num-network-threads' to 3 to avoid netty channel congestion
(#1642)
ab841ba2e is described below
commit ab841ba2eb0dc94909a5847152fe5a5154e1b3ad
Author: yunhong <[email protected]>
AuthorDate: Thu Sep 4 19:40:10 2025 +0800
[client] Change the default value of 'netty.client.num-network-threads' to
3 to avoid netty channel congestion (#1642)
---
fluss-common/src/main/java/org/apache/fluss/config/ConfigOptions.java | 4 ++--
website/docs/maintenance/configuration.md | 2 +-
2 files changed, 3 insertions(+), 3 deletions(-)
diff --git
a/fluss-common/src/main/java/org/apache/fluss/config/ConfigOptions.java
b/fluss-common/src/main/java/org/apache/fluss/config/ConfigOptions.java
index 99e99405a..34effd3af 100644
--- a/fluss-common/src/main/java/org/apache/fluss/config/ConfigOptions.java
+++ b/fluss-common/src/main/java/org/apache/fluss/config/ConfigOptions.java
@@ -739,10 +739,10 @@ public class ConfigOptions {
public static final ConfigOption<Integer> NETTY_CLIENT_NUM_NETWORK_THREADS
=
key("netty.client.num-network-threads")
.intType()
- .defaultValue(1)
+ .defaultValue(3)
.withDescription(
"The number of threads that the client uses for
sending requests to the "
- + "network and receiving responses from
network. The default value is 1");
+ + "network and receiving responses from
network. The default value is 3");
// ------------------------------------------------------------------------
// Client Settings
diff --git a/website/docs/maintenance/configuration.md
b/website/docs/maintenance/configuration.md
index 71b809f63..a38284b45 100644
--- a/website/docs/maintenance/configuration.md
+++ b/website/docs/maintenance/configuration.md
@@ -89,7 +89,7 @@ during the Fluss cluster working.
| netty.server.num-worker-threads | Integer | 8 | The number of
threads that the server uses for processing requests, which may include disk
and remote I/O. |
| netty.server.max-queued-requests | Integer | 500 | The number of queued
requests allowed for worker threads, before blocking the I/O threads.
|
| netty.connection.max-idle-time | Duration | 10min | Close idle
connections after the given time specified by this config.
|
-| netty.client.num-network-threads | Integer | 1 | The number of
threads that the client uses for sending requests to the network and receiving
responses from network. The default value is 1 |
+| netty.client.num-network-threads | Integer | 3 | The number of
threads that the client uses for sending requests to the network and receiving
responses from network. The default value is 3 |
## Log
