rust/greptimedb
1
0
Fork 0
mirror of https://github.com/GreptimeTeam/greptimedb.git synced 2026-01-03 20:02:54 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: time window filter expr use OR

Browse Source
This commit is contained in:
discord9
2025-03-27 15:38:35 +08:00
parent 9fcb0874e2
commit 2974902b8b
1 changed files with 3 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/flow/src/recording_rules/engine.rs
View File

@@ -407,11 +407,8 @@ impl RecordingRuleTask {
.expect("Time went backwards");
let low_bound = self
.expire_after
.map(|e| since_the_epoch.as_secs() - e as u64);
let Some(low_bound) = low_bound else {
return Ok(Some(self.query.clone()));
};
.map(|e| since_the_epoch.as_secs() - e as u64)
.unwrap_or(u64::MIN);
let low_bound = Timestamp::new_second(low_bound as i64);
@@ -607,7 +604,7 @@ impl DirtyTimeWindows {
};
expr_lst.push(expr);
}
let expr = expr_lst.into_iter().reduce(|a, b| a.and(b));
let expr = expr_lst.into_iter().reduce(|a, b| a.or(b));
Ok(expr)
}