diff --git a/src/storage/src/hummock/store/hummock_storage.rs b/src/storage/src/hummock/store/hummock_storage.rs index b3379efa3830..e8df8221756a 100644 --- a/src/storage/src/hummock/store/hummock_storage.rs +++ b/src/storage/src/hummock/store/hummock_storage.rs @@ -406,6 +406,11 @@ impl HummockStorage { let ret = if let Some(info) = info && epoch <= info.committed_epoch { + if epoch < info.committed_epoch { + return Err( + HummockError::expired_epoch(table_id, info.committed_epoch, epoch).into(), + ); + } // read committed_version directly without build snapshot get_committed_read_version_tuple(pinned_version, table_id, key_range, epoch) } else {