Skip to content

Commit

Permalink
avoid break when drop wal failed
Browse files Browse the repository at this point in the history
  • Loading branch information
MichaelLeeHZ committed Apr 4, 2023
1 parent 472d54a commit 6d5ac64
Showing 1 changed file with 7 additions and 1 deletion.
8 changes: 7 additions & 1 deletion wal/src/table_kv_impl/namespace.rs
Original file line number Diff line number Diff line change
Expand Up @@ -1441,7 +1441,13 @@ fn purge_buckets<T: TableKv>(
for bucket in &buckets {
// Delete all tables of this bucket.
for table_name in &bucket.wal_shard_names {
table_kv.drop_table(table_name).map_err(Box::new)?;
let drop_result = table_kv.drop_table(table_name);
if drop_result.is_err() {
error!(
"Purge buckets drop table failed, table:{table_name}, err:{:?}",
drop_result.err()
);
}
}

// All tables of this bucket have been dropped, we can remove the bucket record
Expand Down

0 comments on commit 6d5ac64

Please sign in to comment.