Skip to content

Commit

Permalink
Fix collect ckps in range (#21039)
Browse files Browse the repository at this point in the history
  • Loading branch information
jiangxinmeng1 authored Jan 1, 2025
1 parent 86bbe0d commit 926e28f
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 12 deletions.
8 changes: 0 additions & 8 deletions pkg/vm/engine/tae/db/checkpoint/store.go
Original file line number Diff line number Diff line change
Expand Up @@ -887,14 +887,6 @@ func (s *runnerStore) CollectCheckpointsInRange(
e := iter.Item()
// if it is committed and visible, quick quit
if !e.IsCommitted() || !e.HasOverlap(newStart, end) {
if len(locs) == 0 {
return
}
duration := fmt.Sprintf("[%s_%s]",
ckpStart.ToString(),
ckpStart.ToString())
locs = append(locs, duration)
locations = strings.Join(locs, ";")
return
}
collectEntryFn(e)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ insert into t1 select 1,1,1,utc_timestamp();
insert into t1 select 2,0,0,null;
select a,b,c,year(d) from t1;
a b c year(d)
1 1 1 2024
1 1 1 2025
2 0 0 null
DROP TABLE t1;
CREATE TABLE t1 (a TIMESTAMP);
Expand All @@ -43,8 +43,8 @@ INSERT INTO t1 select (utc_timestamp());
INSERT INTO t1 select (utc_timestamp());
SELECT year(a) FROM t1 WHERE a > '2008-01-01';
year(a)
2024
2024
2024
2025
2025
2025
DROP TABLE t1;
SET TIME_ZONE = "SYSTEM";

0 comments on commit 926e28f

Please sign in to comment.