fix: use flushed_sequence as we can't set sequence in ingester

2026-01-09 14:52:58 +00:00 · 2025-03-10 11:32:16 +08:00
parent 85c346b16a
commit c9f4b36360
1 changed files with 2 additions and 2 deletions
--- a/src/sst-convert/src/reader.rs
+++ b/src/sst-convert/src/reader.rs
@@ -87,7 +87,7 @@ impl InputReaderBuilder {
            self.input_store.clone(),
            &input.path,
            region_info.metadata.clone(),
-            Some(region_info.flushed_sequence + 1),
+            Some(region_info.flushed_sequence),
        )
        .await?;

@@ -112,7 +112,7 @@ impl InputReaderBuilder {
            self.table_helper.clone(),
        )
        .await?
-        .with_sequence(region_info.flushed_sequence + 1);
+        .with_sequence(region_info.flushed_sequence);

        Ok(ReaderInfo {
            reader: Box::new(reader),