From 7b3a175b3550d40370e0da7e3c279c257e0a6ecf Mon Sep 17 00:00:00 2001 From: Vanish Date: Tue, 12 Sep 2023 22:35:04 +0800 Subject: [PATCH] Update src/mito2/src/worker/handle_flush.rs Co-authored-by: Yingwen --- src/mito2/src/worker/handle_flush.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/mito2/src/worker/handle_flush.rs b/src/mito2/src/worker/handle_flush.rs index 5659f7156582..47ef299342d7 100644 --- a/src/mito2/src/worker/handle_flush.rs +++ b/src/mito2/src/worker/handle_flush.rs @@ -43,8 +43,8 @@ impl RegionWorkerLoop { // The flush task before truncating the region. let version_data = region.version_control.current(); - if let Some(truncate_entry_id) = version_data.version.truncate_entry_id { - if truncate_entry_id >= request.flushed_entry_id { + if let Some(truncated_entry_id) = version_data.version.truncated_entry_id { + if truncated_entry_id >= request.flushed_entry_id { request.on_failure(RegionTruncatingSnafu { region_id }.build()); return; }