File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -1755,8 +1755,12 @@ Status DBImpl::MaybeHandleStopReplayForCorruptionForInconsistency(
17551755 ROCKS_LOG_ERROR (immutable_db_options_.info_log ,
17561756 " Column family inconsistency: SST file contains data"
17571757 " beyond the point of corruption." );
1758- status = Status::Corruption (" SST file is ahead of WALs in CF " +
1759- cfd->GetName ());
1758+ status = Status::Corruption (
1759+ " Column family inconsistency: SST file contains data"
1760+ " beyond the point of corruption in CF " +
1761+ cfd->GetName () +
1762+ " . WAL recovery stopped at corruption point, but SST files"
1763+ " contain newer data." );
17601764 return status;
17611765 }
17621766 }
Original file line number Diff line number Diff line change @@ -380,8 +380,11 @@ void Reader::MaybeVerifyPredecessorWALInfo(
380380 } else {
381381 if (observed_predecessor_wal_info_.GetLogNumber () !=
382382 recorded_predecessor_log_number) {
383- std::string reason = " Missing WAL of log number " +
384- std::to_string (recorded_predecessor_log_number);
383+ std::string reason =
384+ " Mismatched predecessor log number of WAL file " +
385+ file_->file_name () + " Recorded " +
386+ std::to_string (recorded_predecessor_log_number) + " . Observed " +
387+ std::to_string (observed_predecessor_wal_info_.GetLogNumber ());
385388 ReportCorruption (fragment.size (), reason.c_str (),
386389 recorded_predecessor_log_number);
387390 } else if (observed_predecessor_wal_info_.GetLastSeqnoRecorded () !=
You can’t perform that action at this time.
0 commit comments