starred/openobserve
1
0
Fork 0
mirror of https://github.com/openobserve/openobserve.git synced 2026-11-05 00:09:35 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: reset stream stats with limit (#6995)

Browse Source
This commit is contained in:
Hengfei Yang
2025-06-02 16:01:43 +08:00
committed by GitHub
parent 3c5ae41210
commit 2cb55bb6b5
2 changed files with 17 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/cli/basic/cli.rs
+3 -14
View File
@@ -327,20 +327,9 @@ pub async fn cli() -> Result<bool, anyhow::Error> {
// load stream list
db::schema::cache().await?;
// update stats from file list
loop {
let ret = compact::stats::update_stats_from_file_list()
.await
.expect("file list remote calculate stats failed");
let Some(offset) = ret else {
break;
};
log::info!(
"keep updating stats from file list, offset: {:?} ...",
offset
);
tokio::time::sleep(tokio::time::Duration::from_millis(50)).await;
}
log::info!("update stats from file list success");
compact::stats::update_stats_from_file_list()
.await
.expect("file list remote calculate stats failed");
}
_ => {
return Err(anyhow::anyhow!(
src/service/compact/stats.rs
+14
View File
@@ -23,6 +23,20 @@ use crate::{
};
pub async fn update_stats_from_file_list() -> Result<Option<(i64, i64)>, anyhow::Error> {
loop {
let Some(offset) = update_stats_from_file_list_inner().await? else {
break;
};
log::info!(
"keep updating stream stats from file list, offset: {:?} ...",
offset
);
tokio::time::sleep(tokio::time::Duration::from_millis(50)).await;
}
Ok(None)
}
async fn update_stats_from_file_list_inner() -> Result<Option<(i64, i64)>, anyhow::Error> {
// get last offset
let (mut offset, node) = db::compact::stats::get_offset().await;
if !node.is_empty() && LOCAL_NODE.uuid.ne(&node) && get_node_by_uuid(&node).await.is_some() {