fix equal check

Signed-off-by: Little-Wallace <[email protected]>
risingwavelabs · Nov 28, 2023 · 8766b07 · 8766b07
1 parent 181a88a
commit 8766b07
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 10 deletions.
diff --git a/src/storage/src/hummock/sstable/builder.rs b/src/storage/src/hummock/sstable/builder.rs
@@ -398,7 +398,7 @@ impl<W: SstableWriter, F: FilterBuilder> SstableBuilder<W, F> {
         assert!(self.monotonic_deletes.is_empty() || self.monotonic_deletes.len() > 1);
 
         if let Some(monotonic_delete) = self.monotonic_deletes.last() {
-            assert_eq!(monotonic_delete.new_epoch, HummockEpoch::MAX);
+            assert!(monotonic_delete.new_epoch >= MAX_EPOCH);
             if monotonic_delete.event_key.is_exclude_left_key {
                 if largest_key.is_empty()
                     || !KeyComparator::encoded_greater_than_unencoded(
@@ -430,7 +430,7 @@ impl<W: SstableWriter, F: FilterBuilder> SstableBuilder<W, F> {
             }
         }
         if let Some(monotonic_delete) = self.monotonic_deletes.first() {
-            assert_ne!(monotonic_delete.new_epoch, HummockEpoch::MAX);
+            assert!(monotonic_delete.new_epoch < MAX_EPOCH);
             if smallest_key.is_empty()
                 || !KeyComparator::encoded_less_than_unencoded(
                     user_key(&smallest_key),

diff --git a/src/storage/src/hummock/sstable/delete_range_aggregator.rs b/src/storage/src/hummock/sstable/delete_range_aggregator.rs
@@ -260,14 +260,8 @@ impl CompactionDeleteRanges {
                 && a.new_epoch == b.new_epoch
         });
         if !monotonic_events.is_empty() {
-            assert_ne!(
-                monotonic_events.first().unwrap().new_epoch,
-                HummockEpoch::MAX
-            );
-            assert_eq!(
-                monotonic_events.last().unwrap().new_epoch,
-                HummockEpoch::MAX
-            );
+            assert!(monotonic_events.first().unwrap().new_epoch < MAX_EPOCH);
+            assert!(monotonic_events.last().unwrap().new_epoch >= MAX_EPOCH);
         }
         monotonic_events
     }