Skip to content

Commit

Permalink
MB-50165 Do not force snapshot if initFlushTs is greater than mergeTs
Browse files Browse the repository at this point in the history
If initFlushTs is greater than maintTs, then timekeeper will endup
in a snapshotting loop and will never come out of it

Change-Id: I627f4cda68d9b45934877771b7fb3d5e30e711e6
  • Loading branch information
varunv-cb committed Dec 21, 2021
1 parent e01dcd7 commit dfed9f7
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion secondary/indexer/timekeeper.go
Original file line number Diff line number Diff line change
Expand Up @@ -2493,7 +2493,7 @@ func (tk *timekeeper) checkInitStreamReadyToMerge(streamId common.StreamId,
mergeTs = initFlushTs
}

if initFlushTs.Equal2(mergeTs, false) {
if initFlushTs.EqualOrGreater(mergeTs, false) {
forceSnapshot = false
}

Expand Down

0 comments on commit dfed9f7

Please sign in to comment.