database/doris
2
0
Fork 0
Code Issues Pull Requests Actions 3 Packages Projects Releases Wiki Activity

[improve](move-memtable) reduce default load stream per node to 2 for stream load (#34065) (#34205)

Browse Source 
Co-authored-by: Kaijie Chen <ckj@apache.org>
This commit is contained in:
Xin Liao
2024-04-27 18:20:57 +08:00
committed by GitHub
parent cd1c9edd71
commit 7ab425ee4b
3 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
fe/fe-core/src/main/java/org/apache/doris/service/FrontendServiceImpl.java
View File

@ -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();
}

2
fe/fe-core/src/main/java/org/apache/doris/task/LoadTaskInfo.java
View File

@ -126,7 +126,7 @@ public interface LoadTaskInfo {
}
default int getStreamPerNode() {
return 20;
return 2;
}
class ImportColumnDescs {

2
fe/fe-core/src/main/java/org/apache/doris/task/StreamLoadTask.java
View File

@ -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;