From 9f8a91598d7f29be5317ed266431727de1235b6a Mon Sep 17 00:00:00 2001 From: dl239 Date: Wed, 1 Nov 2023 11:00:13 +0800 Subject: [PATCH] fix: fix isExpire --- src/storage/mem_table.cc | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/src/storage/mem_table.cc b/src/storage/mem_table.cc index 02290f709f5..7c7005272dd 100644 --- a/src/storage/mem_table.cc +++ b/src/storage/mem_table.cc @@ -433,6 +433,11 @@ bool MemTable::IsExpire(const LogEntry& entry) { } } const int8_t* data = reinterpret_cast(entry.value().data()); + std::string uncompress_data; + if (GetCompressType() == openmldb::type::kSnappy) { + snappy::Uncompress(entry.value().data(), entry.value().size(), &uncompress_data); + data = reinterpret_cast(uncompress_data.data()); + } uint8_t version = codec::RowView::GetSchemaVersion(data); auto decoder = GetVersionDecoder(version); if (decoder == nullptr) {