fix: don't skip wal in test

This commit is contained in:
Lei, HUANG
2023-03-14 11:09:58 +08:00
parent 9b4dcba8cf
commit 7ee54b3e69
2 changed files with 8 additions and 9 deletions

View File

@@ -376,15 +376,11 @@ impl WriterInner {
let version = version_control.current();
let region_id = writer_ctx.shared.id;
// table with id less than MIN_USER_TABLE_ID is system table
if (region_id >> 32) < 1024 {
let wal_header = WalHeader::with_last_manifest_version(version.manifest_version());
writer_ctx
.wal
.write_to_wal(next_sequence, wal_header, Some(request.payload()))
.await?;
}
let wal_header = WalHeader::with_last_manifest_version(version.manifest_version());
writer_ctx
.wal
.write_to_wal(next_sequence, wal_header, Some(request.payload()))
.await?;
// Insert batch into memtable.
let mut inserter = Inserter::new(next_sequence);

View File

@@ -106,6 +106,9 @@ impl<S: LogStore> Wal<S> {
mut header: WalHeader,
payload: Option<&Payload>,
) -> Result<Id> {
if !cfg!(test) && (self.region_id >> 32) >= 1024 {
return Ok(seq);
}
if let Some(p) = payload {
header.mutation_types = wal::gen_mutation_types(p);
}