fix: off-by-one in catalog update logic (#26129)

2025-03-12 12:03:50 -04:00 · 2025-03-12 12:03:50 -04:00 · 1fb03b3daa
parent a455598be6
commit 1fb03b3daa
1 changed files with 1 additions and 1 deletions
--- a/influxdb3_catalog/src/catalog/update.rs
+++ b/influxdb3_catalog/src/catalog/update.rs
@ -694,7 +694,7 @@ impl Catalog {
            let batch = self.apply_ordered_catalog_batch(&ordered_catalog_batch, permit);
            self.broadcast_update(batch);
            sequence_number = sequence_number.next();
-            if update_until.is_some_and(|max_sequence| sequence_number >= max_sequence) {
+            if update_until.is_some_and(|max_sequence| sequence_number > max_sequence) {
                break;
            }
        }