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

morningman · Nov 14, 2023 · 8b097af · 8b097af
1 parent fad6770
commit 8b097af
Showing 1 changed file with 7 additions and 0 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
@@ -2156,6 +2156,13 @@ private void httpStreamPutImpl(TStreamLoadPutRequest request, TStreamLoadPutResu
             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());