diff --git a/db/compaction/compaction_job.cc b/db/compaction/compaction_job.cc index 35e80e7c6..a76e91696 100644 --- a/db/compaction/compaction_job.cc +++ b/db/compaction/compaction_job.cc @@ -1961,7 +1961,10 @@ void CompactionJob::LogCompaction() { stream.EndArray(); } stream << "score" << compaction->score() << "input_data_size" - << compaction->CalculateTotalInputSize(); + << compaction->CalculateTotalInputSize() << "oldest_snapshot_seqno" + << (existing_snapshots_.empty() + ? int64_t{-1} // Use -1 for "none" + : static_cast(existing_snapshots_[0])); } } diff --git a/db/event_helpers.cc b/db/event_helpers.cc index 3f290cc05..6a5c93661 100644 --- a/db/event_helpers.cc +++ b/db/event_helpers.cc @@ -97,7 +97,8 @@ void EventHelpers::LogAndNotifyTableFileCreationFinished( << "file_number" << fd.GetNumber() << "file_size" << fd.GetFileSize() << "file_checksum" << Slice(file_checksum).ToString(true) << "file_checksum_func_name" - << file_checksum_func_name; + << file_checksum_func_name << "smallest_seqno" << fd.smallest_seqno + << "largest_seqno" << fd.largest_seqno; // table_properties {