This is an automated email from the ASF dual-hosted git repository.
liaoxin pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 7ab425ee4b6 [improve](move-memtable) reduce default load stream per
node to 2 for stream load (#34065) (#34205)
7ab425ee4b6 is described below
commit 7ab425ee4b67ff20e6e7689f71bcfabad63519f8
Author: Xin Liao <liaoxin...@126.com>
AuthorDate: Sat Apr 27 18:20:57 2024 +0800
[improve](move-memtable) reduce default load stream per node to 2 for
stream load (#34065) (#34205)
Co-authored-by: Kaijie Chen <c...@apache.org>
---
.../src/main/java/org/apache/doris/service/FrontendServiceImpl.java | 2 +-
fe/fe-core/src/main/java/org/apache/doris/task/LoadTaskInfo.java | 2 +-
fe/fe-core/src/main/java/org/apache/doris/task/StreamLoadTask.java | 2 +-
3 files changed, 3 insertions(+), 3 deletions(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java
b/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java
index 538a1f9893e..1d69c945805 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java
@@ -2085,7 +2085,7 @@ public class FrontendServiceImpl implements
FrontendService.Iface {
ctx.getSessionVariable().groupCommit = request.getGroupCommitMode();
try {
HttpStreamParams httpStreamParams = initHttpStreamPlan(request,
ctx);
- int loadStreamPerNode = 20;
+ int loadStreamPerNode = 2;
if (request.getStreamPerNode() > 0) {
loadStreamPerNode = request.getStreamPerNode();
}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/task/LoadTaskInfo.java
b/fe/fe-core/src/main/java/org/apache/doris/task/LoadTaskInfo.java
index 8671933f758..8f641070c40 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/task/LoadTaskInfo.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/task/LoadTaskInfo.java
@@ -126,7 +126,7 @@ public interface LoadTaskInfo {
}
default int getStreamPerNode() {
- return 20;
+ return 2;
}
class ImportColumnDescs {
diff --git a/fe/fe-core/src/main/java/org/apache/doris/task/StreamLoadTask.java
b/fe/fe-core/src/main/java/org/apache/doris/task/StreamLoadTask.java
index f663eb65913..94f3625fbc7 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/task/StreamLoadTask.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/task/StreamLoadTask.java
@@ -89,7 +89,7 @@ public class StreamLoadTask implements LoadTaskInfo {
private boolean enableProfile = false;
private boolean memtableOnSinkNode = false;
- private int streamPerNode = 20;
+ private int streamPerNode = 2;
private byte enclose = 0;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
