mirror of
https://github.com/GreptimeTeam/greptimedb.git
synced 2026-01-07 05:42:57 +00:00
fix: find latest window (#5037)
* fix: find latest window * more test files
This commit is contained in:
@@ -353,10 +353,10 @@ fn find_latest_window_in_seconds<'a>(
|
||||
let mut latest_timestamp = None;
|
||||
for f in files {
|
||||
let (_, end) = f.time_range();
|
||||
if let Some(latest) = latest_timestamp
|
||||
&& end > latest
|
||||
{
|
||||
latest_timestamp = Some(end);
|
||||
if let Some(latest) = latest_timestamp {
|
||||
if end > latest {
|
||||
latest_timestamp = Some(end);
|
||||
}
|
||||
} else {
|
||||
latest_timestamp = Some(end);
|
||||
}
|
||||
@@ -406,6 +406,18 @@ mod tests {
|
||||
)
|
||||
.unwrap()
|
||||
);
|
||||
|
||||
assert_eq!(
|
||||
Some((i64::MAX / 3600000 + 1) * 3600),
|
||||
find_latest_window_in_seconds(
|
||||
[
|
||||
new_file_handle(FileId::random(), i64::MIN, i64::MAX, 0),
|
||||
new_file_handle(FileId::random(), 0, 1000, 0)
|
||||
]
|
||||
.iter(),
|
||||
3600
|
||||
)
|
||||
);
|
||||
}
|
||||
|
||||
#[test]
|
||||
|
||||
Reference in New Issue
Block a user