This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-4.0 by this push:
new 5db833025d7 branch-4.0: [chore] (streamload) add enable stream load
profile config #57919 (#58029)
5db833025d7 is described below
commit 5db833025d734ea88ae5ecebe0d8aa17441066bb
Author: github-actions[bot]
<41898282+github-actions[bot]@users.noreply.github.com>
AuthorDate: Sat Nov 15 12:18:51 2025 +0800
branch-4.0: [chore] (streamload) add enable stream load profile config
#57919 (#58029)
Cherry-picked from #57919
Co-authored-by: HonestManXin <[email protected]>
Co-authored-by: zhangshixin.1024 <[email protected]>
---
fe/fe-common/src/main/java/org/apache/doris/common/Config.java | 6 ++++++
.../org/apache/doris/nereids/load/NereidsStreamLoadPlanner.java | 4 ++--
2 files changed, 8 insertions(+), 2 deletions(-)
diff --git a/fe/fe-common/src/main/java/org/apache/doris/common/Config.java
b/fe/fe-common/src/main/java/org/apache/doris/common/Config.java
index 67e7e918a03..250b272289e 100644
--- a/fe/fe-common/src/main/java/org/apache/doris/common/Config.java
+++ b/fe/fe-common/src/main/java/org/apache/doris/common/Config.java
@@ -693,6 +693,12 @@ public class Config extends ConfigBase {
"Whether to disable show stream load and clear stream load records
in memory."})
public static boolean disable_show_stream_load = false;
+ @ConfField(mutable = true, description = {
+ "是否开启stream load profile",
+ "Whether to enable stream load profile"
+ })
+ public static boolean enable_stream_load_profile = false;
+
@ConfField(mutable = true, masterOnly = true, description = {
"是否启用 stream load 和 broker load 的单副本写入。",
"Whether to enable to write single replica for stream load and
broker load."},
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/nereids/load/NereidsStreamLoadPlanner.java
b/fe/fe-core/src/main/java/org/apache/doris/nereids/load/NereidsStreamLoadPlanner.java
index 09fba057a91..e74128f94fd 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/nereids/load/NereidsStreamLoadPlanner.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/nereids/load/NereidsStreamLoadPlanner.java
@@ -306,8 +306,8 @@ public class NereidsStreamLoadPlanner {
queryOptions.setLoadMemLimit(taskInfo.getMemLimit());
// load
queryOptions.setBeExecVersion(Config.be_exec_version);
- queryOptions.setIsReportSuccess(taskInfo.getEnableProfile());
- queryOptions.setEnableProfile(taskInfo.getEnableProfile());
+ queryOptions.setIsReportSuccess(taskInfo.getEnableProfile() ||
Config.enable_stream_load_profile);
+ queryOptions.setEnableProfile(taskInfo.getEnableProfile() ||
Config.enable_stream_load_profile);
boolean enableMemtableOnSinkNode =
destTable.getTableProperty().getUseSchemaLightChange()
? taskInfo.isMemtableOnSinkNode()
: false;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
