rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-01-09 14:52:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: yield after get ranges

Browse Source
This commit is contained in:
evenyag
2024-11-08 01:28:39 +08:00
parent 9a6c7aa4d6
commit 65e53b5bc4
1 changed files with 5 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
src/mito2/src/read/scan_util.rs
View File

@@ -22,6 +22,7 @@ use common_telemetry::debug;
use futures::Stream;
use prometheus::IntGauge;
use store_api::storage::RegionId;
use tokio::task::yield_now;
use crate::error::Result;
use crate::metrics::SCAN_PARTITION;
@@ -194,6 +195,10 @@ pub(crate) fn scan_file_ranges(
.build_file_ranges(index, read_type, &mut reader_metrics)
.await?;
part_metrics.inc_num_file_ranges(ranges.len());
// Notify other partitions.
yield_now().await;
if read_type == "unordered_scan_files" {
common_telemetry::debug!(
"[DEBUG_SCAN] Thread: {:?}, Scan file ranges build ranges end, region_id: {}, partition: {}, index: {:?}, ranges: {}",