From 7f47b0a54130f2a39fc4ccd73797dab8f6097301 Mon Sep 17 00:00:00 2001 From: zhiqiang-hhhh Date: Wed, 29 Oct 2025 22:42:11 +0800 Subject: [PATCH 1/2] FIX --- be/src/vec/exec/scan/scanner.cpp | 4 +++- .../src/main/java/org/apache/doris/qe/SessionVariable.java | 2 +- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/be/src/vec/exec/scan/scanner.cpp b/be/src/vec/exec/scan/scanner.cpp index dc7133927b1f02..e91abd6be534ee 100644 --- a/be/src/vec/exec/scan/scanner.cpp +++ b/be/src/vec/exec/scan/scanner.cpp @@ -244,7 +244,9 @@ Status Scanner::close(RuntimeState* state) { void Scanner::_collect_profile_before_close() { COUNTER_UPDATE(_local_state->_scan_cpu_timer, _scan_cpu_timer); COUNTER_UPDATE(_local_state->_rows_read_counter, _num_rows_read); - if (!_state->enable_profile() && !_is_load) return; + if (!_is_load) { + return; + } // Update stats for load _state->update_num_rows_load_filtered(_counter.num_rows_filtered); _state->update_num_rows_load_unselected(_counter.num_rows_unselected); diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java index 7582a7b6b6d7aa..3ea60c3cbc82d1 100644 --- a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java +++ b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java @@ -1021,7 +1021,7 @@ public static double getHotValueThreshold() { // if true, need report to coordinator when plan fragment execute successfully. @VariableMgr.VarAttr(name = ENABLE_PROFILE, needForward = true) - public boolean enableProfile = true; + public boolean enableProfile = false; @VariableMgr.VarAttr(name = RPC_VERBOSE_PROFILE_MAX_INSTANCE_COUNT, needForward = true) public int rpcVerboseProfileMaxInstanceCount = 5; From fe439345c36bdb2b20d1f46a9a57b9b8f005e6e7 Mon Sep 17 00:00:00 2001 From: zhiqiang-hhhh Date: Thu, 30 Oct 2025 10:36:18 +0800 Subject: [PATCH 2/2] DDS --- be/src/vec/exec/scan/scanner.cpp | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/be/src/vec/exec/scan/scanner.cpp b/be/src/vec/exec/scan/scanner.cpp index e91abd6be534ee..77b9a54cb7a32e 100644 --- a/be/src/vec/exec/scan/scanner.cpp +++ b/be/src/vec/exec/scan/scanner.cpp @@ -244,9 +244,7 @@ Status Scanner::close(RuntimeState* state) { void Scanner::_collect_profile_before_close() { COUNTER_UPDATE(_local_state->_scan_cpu_timer, _scan_cpu_timer); COUNTER_UPDATE(_local_state->_rows_read_counter, _num_rows_read); - if (!_is_load) { - return; - } + // Update stats for load _state->update_num_rows_load_filtered(_counter.num_rows_filtered); _state->update_num_rows_load_unselected(_counter.num_rows_unselected);