This is an automated email from the ASF dual-hosted git repository.
dataroaring pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new b78830d5732 [config](move-memtable) support HTTP header
load_stream_per_node in stream load (#34444)
b78830d5732 is described below
commit b78830d57325e5cd4055051669ed1680e5aafecb
Author: Kaijie Chen <[email protected]>
AuthorDate: Wed May 8 21:37:11 2024 +0800
[config](move-memtable) support HTTP header load_stream_per_node in stream
load (#34444)
---
be/src/http/action/stream_load.cpp | 4 ++++
be/src/http/http_common.h | 1 +
2 files changed, 5 insertions(+)
diff --git a/be/src/http/action/stream_load.cpp
b/be/src/http/action/stream_load.cpp
index 80696fd4f6a..eb8d364cf59 100644
--- a/be/src/http/action/stream_load.cpp
+++ b/be/src/http/action/stream_load.cpp
@@ -621,6 +621,10 @@ Status StreamLoadAction::_process_put(HttpRequest*
http_req,
bool value = iequal(http_req->header(HTTP_MEMTABLE_ON_SINKNODE),
"true");
request.__set_memtable_on_sink_node(value);
}
+ if (!http_req->header(HTTP_LOAD_STREAM_PER_NODE).empty()) {
+ int value = std::stoi(http_req->header(HTTP_LOAD_STREAM_PER_NODE));
+ request.__set_stream_per_node(value);
+ }
if (ctx->group_commit) {
if (!http_req->header(HTTP_GROUP_COMMIT).empty()) {
request.__set_group_commit_mode(http_req->header(HTTP_GROUP_COMMIT));
diff --git a/be/src/http/http_common.h b/be/src/http/http_common.h
index 517ee87c685..ec2dfc896e4 100644
--- a/be/src/http/http_common.h
+++ b/be/src/http/http_common.h
@@ -64,6 +64,7 @@ static const std::string HTTP_TWO_PHASE_COMMIT =
"two_phase_commit";
static const std::string HTTP_TXN_ID_KEY = "txn_id";
static const std::string HTTP_TXN_OPERATION_KEY = "txn_operation";
static const std::string HTTP_MEMTABLE_ON_SINKNODE = "memtable_on_sink_node";
+static const std::string HTTP_LOAD_STREAM_PER_NODE = "load_stream_per_node";
static const std::string HTTP_WAL_ID_KY = "wal_id";
static const std::string HTTP_AUTH_CODE = "auth_code";
static const std::string HTTP_GROUP_COMMIT = "group_commit";
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
