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

[fix](move-memtable) support http stream (#26929)

Browse Source
This commit is contained in:
Kaijie Chen
2023-11-14 20:19:57 +08:00
committed by GitHub
parent fad6770225
commit 8b097af9fa
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -2156,6 +2156,13 @@ public class FrontendServiceImpl implements FrontendService.Iface {
coord.setQueryType(TQueryType.LOAD);
TExecPlanFragmentParams plan = coord.getStreamLoadPlan();
int loadStreamPerNode = 20;
if (request.getStreamPerNode() > 0) {
loadStreamPerNode = request.getStreamPerNode();
}
plan.setLoadStreamPerNode(loadStreamPerNode);
plan.setTotalLoadStreams(loadStreamPerNode);
plan.setNumLocalSink(1);
final long txn_id = parsedStmt.getTransactionId();
result.setParams(plan);
result.getParams().setDbName(parsedStmt.getDbName());