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

chore: Revert "chore: Revert "feat: yield after get ranges""

Browse Source 
This reverts commit 770a850437.
This commit is contained in:
evenyag
2024-11-08 17:12:54 +08:00
parent 50d28e0a00
commit 999f3a40c2
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

@@ -23,6 +23,7 @@ use futures::Stream;
use prometheus::IntGauge;
use snafu::ResultExt;
use store_api::storage::RegionId;
use tokio::task::yield_now;
use crate::error::{Result, TimeoutSnafu};
use crate::metrics::SCAN_PARTITION;
@@ -218,6 +219,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: {}",