Skip to content

Commit

Permalink
fix CI
Browse files Browse the repository at this point in the history
  • Loading branch information
jiacai2050 committed Oct 12, 2023
1 parent 57635ec commit 393ba0a
Showing 1 changed file with 3 additions and 10 deletions.
13 changes: 3 additions & 10 deletions wal/src/table_kv_impl/table_unit.rs
Original file line number Diff line number Diff line change
Expand Up @@ -479,12 +479,12 @@ impl TableUnit {
// may be greater than the `actual last sequence of written logs`.
//
// Such as following case:
// + Write wal logs failed(last sequence stored in memory will increase when write failed).
// + Get last sequence from memory(greater then actual last sequence now).
// + Write wal logs failed(last sequence stored in memory will increase when write failed).
// + Get last sequence from memory(greater then actual last sequence now).
// + Mark the got last sequence as flushed sequence.
let actual_next_sequence = sequence + 1;
if actual_next_sequence < start_sequence {
warn!("TableKv WAL found start_sequence greater than actual_next_sequence,
warn!("TableKv WAL found start_sequence greater than actual_next_sequence,
start_sequence:{start_sequence}, actual_next_sequence:{actual_next_sequence}, table_id:{table_id}, region_id:{region_id}");

break;
Expand Down Expand Up @@ -996,13 +996,6 @@ impl TableUnitWriter {
table_unit_state.table_id, sequence_num, table_unit_meta_table
);

ensure!(
sequence_num < common_types::MAX_SEQUENCE_NUMBER,
SequenceOverflow {
table_id: table_unit_state.table_id,
}
);

let last_sequence = table_unit_state.last_sequence();
if sequence_num > last_sequence {
sequence_num = last_sequence;
Expand Down

0 comments on commit 393ba0a

Please sign in to comment.