This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch tpc_preview6
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/tpc_preview6 by this push:
new 4049654de6d [opt](profile) change some metrics' level in profile
4049654de6d is described below
commit 4049654de6db0c75b69f4baa9775c454c4212783
Author: morningman <[email protected]>
AuthorDate: Wed Jan 28 12:16:31 2026 +0800
[opt](profile) change some metrics' level in profile
---
be/src/runtime_filter/runtime_filter_consumer.cpp | 4 ++--
be/src/vec/exec/format/parquet/vparquet_group_reader.cpp | 1 -
.../src/main/java/org/apache/doris/common/profile/RuntimeProfile.java | 3 ++-
3 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/be/src/runtime_filter/runtime_filter_consumer.cpp
b/be/src/runtime_filter/runtime_filter_consumer.cpp
index a99f7bfd874..19defeb394f 100644
--- a/be/src/runtime_filter/runtime_filter_consumer.cpp
+++ b/be/src/runtime_filter/runtime_filter_consumer.cpp
@@ -235,11 +235,11 @@ void
RuntimeFilterConsumer::collect_realtime_profile(RuntimeProfile* parent_oper
"RuntimeFilterInfo", 1);
c->update(_rf_filter->value());
c = parent_operator_profile->add_counter(fmt::format("RF{} WaitTime",
filter_id),
- TUnit::TIME_NS,
"RuntimeFilterInfo", 2);
+ TUnit::TIME_NS,
"RuntimeFilterInfo", 1);
c->update(_wait_timer->value());
c = parent_operator_profile->add_counter(fmt::format("RF{}
AlwaysTrueFilterRows", filter_id),
- TUnit::UNIT, "RuntimeFilterInfo",
2);
+ TUnit::UNIT, "RuntimeFilterInfo",
1);
c->update(_always_true_counter->value());
}
diff --git a/be/src/vec/exec/format/parquet/vparquet_group_reader.cpp
b/be/src/vec/exec/format/parquet/vparquet_group_reader.cpp
index 88d083e10d2..06038cd876e 100644
--- a/be/src/vec/exec/format/parquet/vparquet_group_reader.cpp
+++ b/be/src/vec/exec/format/parquet/vparquet_group_reader.cpp
@@ -513,7 +513,6 @@ Status RowGroupReader::_do_lazy_read(Block* block, size_t
batch_size, size_t* re
}
{
- SCOPED_RAW_TIMER(&_predicate_filter_time);
RETURN_IF_ERROR(VExprContext::execute_conjuncts(filter_contexts, &filters,
block,
&result_filter, &can_filter_all));
}
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/common/profile/RuntimeProfile.java
b/fe/fe-core/src/main/java/org/apache/doris/common/profile/RuntimeProfile.java
index 4ee72f5c100..2f499a8dd4c 100644
---
a/fe/fe-core/src/main/java/org/apache/doris/common/profile/RuntimeProfile.java
+++
b/fe/fe-core/src/main/java/org/apache/doris/common/profile/RuntimeProfile.java
@@ -497,7 +497,8 @@ public class RuntimeProfile {
}
boolean shouldBeIncluded() {
- if (Objects.equals(this.name, "CommonCounters") ||
Objects.equals(this.name, "CustomCounters")) {
+ if (Objects.equals(this.name, "CommonCounters") ||
Objects.equals(this.name, "CustomCounters")
+ || Objects.equals(this.name, "Scanner")) {
return true;
} else {
return this.name.matches(".*Pipeline.*") ||
this.name.matches(".*_OPERATOR.*");
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
