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 b439484f7c7 [improve](cloud) Add profile for sync_rowsets while
quering (#35869)
b439484f7c7 is described below
commit b439484f7c7529b34ad0298c2bc31bd57b478fc5
Author: huanghaibin <[email protected]>
AuthorDate: Tue Jun 4 22:51:49 2024 +0800
[improve](cloud) Add profile for sync_rowsets while quering (#35869)
Add profile for sync_rowsets while quering.
---
be/src/pipeline/exec/olap_scan_operator.cpp | 5 ++++-
be/src/pipeline/exec/olap_scan_operator.h | 1 +
2 files changed, 5 insertions(+), 1 deletion(-)
diff --git a/be/src/pipeline/exec/olap_scan_operator.cpp
b/be/src/pipeline/exec/olap_scan_operator.cpp
index 0b1fbee0c80..5b458314d25 100644
--- a/be/src/pipeline/exec/olap_scan_operator.cpp
+++ b/be/src/pipeline/exec/olap_scan_operator.cpp
@@ -60,6 +60,7 @@ Status OlapScanLocalState::_init_profile() {
_block_load_counter = ADD_COUNTER(_segment_profile, "BlocksLoad",
TUnit::UNIT);
_block_fetch_timer = ADD_TIMER(_scanner_profile, "BlockFetchTime");
_delete_bitmap_get_agg_timer = ADD_TIMER(_scanner_profile,
"DeleteBitmapGetAggTime");
+ _sync_rowset_timer = ADD_TIMER(_scanner_profile, "SyncRowsetTime");
_raw_rows_counter = ADD_COUNTER(_segment_profile, "RawRowsRead",
TUnit::UNIT);
_block_convert_timer = ADD_TIMER(_scanner_profile, "BlockConvertTime");
_block_init_timer = ADD_TIMER(_segment_profile, "BlockInitTime");
@@ -278,8 +279,9 @@ Status
OlapScanLocalState::_init_scanners(std::list<vectorized::VScannerSPtr>* s
scan_range->version.data() +
scan_range->version.size(), version);
tablets.emplace_back(std::move(tablet), version);
}
-
+ int64_t duration_ns = 0;
if (config::is_cloud_mode()) {
+ SCOPED_RAW_TIMER(&duration_ns);
std::vector<std::function<Status()>> tasks;
tasks.reserve(_scan_ranges.size());
for (auto&& [tablet, version] : tablets) {
@@ -289,6 +291,7 @@ Status
OlapScanLocalState::_init_scanners(std::list<vectorized::VScannerSPtr>* s
}
RETURN_IF_ERROR(cloud::bthread_fork_join(tasks, 10));
}
+ _sync_rowset_timer->update(duration_ns);
if (enable_parallel_scan && !p._should_run_serial && !has_cpu_limit &&
p._push_down_agg_type == TPushAggOp::NONE &&
diff --git a/be/src/pipeline/exec/olap_scan_operator.h
b/be/src/pipeline/exec/olap_scan_operator.h
index c4f4d864dd9..ca98b171189 100644
--- a/be/src/pipeline/exec/olap_scan_operator.h
+++ b/be/src/pipeline/exec/olap_scan_operator.h
@@ -135,6 +135,7 @@ private:
RuntimeProfile::Counter* _block_fetch_timer = nullptr;
RuntimeProfile::Counter* _delete_bitmap_get_agg_timer = nullptr;
+ RuntimeProfile::Counter* _sync_rowset_timer = nullptr;
RuntimeProfile::Counter* _block_load_timer = nullptr;
RuntimeProfile::Counter* _block_load_counter = nullptr;
// Add more detail seek timer and counter profile
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
