From c9f4b363603a9affc44ac77aae5c23397bce0620 Mon Sep 17 00:00:00 2001 From: evenyag Date: Mon, 10 Mar 2025 11:32:16 +0800 Subject: [PATCH] fix: use flushed_sequence as we can't set sequence in ingester --- src/sst-convert/src/reader.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/sst-convert/src/reader.rs b/src/sst-convert/src/reader.rs index a8dabc9981..0279d23664 100644 --- 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),