This is an automated email from the ASF dual-hosted git repository.
yiguolei pushed a commit to branch branch-2.1
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.1 by this push:
new 341f5cd7a34 [fix](branch-2.1) Fix streamload profile not set (#34221)
341f5cd7a34 is described below
commit 341f5cd7a3464fcee6f71c6a494b08b808504e25
Author: zhiqiang <[email protected]>
AuthorDate: Sun Apr 28 14:36:58 2024 +0800
[fix](branch-2.1) Fix streamload profile not set (#34221)
---
be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp | 5 +++--
.../src/main/java/org/apache/doris/planner/StreamLoadPlanner.java | 2 ++
2 files changed, 5 insertions(+), 2 deletions(-)
diff --git a/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp
b/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp
index 53d3a1bc5d0..5c92091e3bf 100644
--- a/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp
+++ b/be/src/pipeline/pipeline_x/pipeline_x_fragment_context.cpp
@@ -1369,8 +1369,9 @@ void PipelineXFragmentContext::_close_fragment_instance()
{
// After add the operation, the print out like that:
// UNION_NODE (id=0):(Active: 56.720us, non-child: 82.53%)
// We can easily know the exec node execute time without child time
consumed.
- _runtime_state->runtime_profile()->compute_time_in_profile();
- _runtime_state->runtime_profile()->pretty_print(&ss);
+ for (auto& profile : _runtime_state->pipeline_id_to_profile()) {
+ profile->pretty_print(&ss);
+ }
if (_runtime_state->load_channel_profile()) {
_runtime_state->load_channel_profile()->pretty_print(&ss);
}
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/planner/StreamLoadPlanner.java
b/fe/fe-core/src/main/java/org/apache/doris/planner/StreamLoadPlanner.java
index 8f75f5476f8..4d63a92c750 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/planner/StreamLoadPlanner.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/planner/StreamLoadPlanner.java
@@ -324,6 +324,7 @@ public class StreamLoadPlanner {
queryOptions.setEnablePipelineEngine(Config.enable_pipeline_load);
queryOptions.setBeExecVersion(Config.be_exec_version);
queryOptions.setIsReportSuccess(taskInfo.getEnableProfile());
+ queryOptions.setEnableProfile(taskInfo.getEnableProfile());
boolean isEnableMemtableOnSinkNode =
destTable.getTableProperty().getUseSchemaLightChange()
? taskInfo.isMemtableOnSinkNode() : false;
@@ -556,6 +557,7 @@ public class StreamLoadPlanner {
queryOptions.setEnablePipelineEngine(Config.enable_pipeline_load);
queryOptions.setBeExecVersion(Config.be_exec_version);
queryOptions.setIsReportSuccess(taskInfo.getEnableProfile());
+ queryOptions.setEnableProfile(taskInfo.getEnableProfile());
boolean isEnableMemtableOnSinkNode =
destTable.getTableProperty().getUseSchemaLightChange()
? taskInfo.isMemtableOnSinkNode() : false;
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
