MINOR: LogLoader: Add log identifier at few missing areas
Reviewers: Jun Rao
@@ -373,7 +373,7 @@ object LogLoader extends Logging {
params.config,
time = params.time,
fileSuffix = Log.SwapFileSuffix)
- info(s"Found log file ${swapFile.getPath} from interrupted swap operation, repairing.")
+ info(s"${params.logIdentifier}Found log file ${swapFile.getPath} from interrupted swap operation, repairing.")
recoverSegment(swapSegment, params)
// We create swap files for two cases:
@@ -425,7 +425,8 @@ object LogLoader extends Logging {
if (logEndOffset >= params.logStartOffsetCheckpoint)
Some(logEndOffset)
else {
- warn(s"Deleting all segments because logEndOffset ($logEndOffset) is smaller than logStartOffset ${params.logStartOffsetCheckpoint}. " +
+ warn(s"${params.logIdentifier}Deleting all segments because logEndOffset ($logEndOffset) " +
+ s" smaller than logStartOffset ${params.logStartOffsetCheckpoint}." +
" This could happen if segment files were deleted from the file system.")
removeAndDeleteSegmentsAsync(params.segments.values, params)
params.leaderEpochCache.foreach(_.clearAndFlush())
@@ -514,7 +515,7 @@ object LogLoader extends Logging {
// materialization of the iterator here, so that results of the iteration remain valid and
// deterministic.
val toDelete = segmentsToDelete.toList
- info(s"Deleting segments as part of log recovery: ${toDelete.mkString(",")}")
+ info(s"${params.logIdentifier}Deleting segments as part of log recovery: ${toDelete.mkString(",")}")
toDelete.foreach { segment =>
params.segments.remove(segment.baseOffset)
}
