fix: fix isExpire

4paradigm · Nov 1, 2023 · 9f8a915 · 9f8a915
1 parent 4112c7c
commit 9f8a915
Showing 1 changed file with 5 additions and 0 deletions.
diff --git 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<const int8_t*>(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<const int8_t*>(uncompress_data.data());
+    }
     uint8_t version = codec::RowView::GetSchemaVersion(data);
     auto decoder = GetVersionDecoder(version);
     if (decoder == nullptr) {