MINOR: Fix missing word in LogLoader logged warning
Reviewers: David Arthur
@@ -403,7 +403,7 @@ object LogLoader extends Logging {
Some(logEndOffset)
else {
warn(s"${params.logIdentifier}Deleting all segments because logEndOffset ($logEndOffset) " +
- s" smaller than logStartOffset ${params.logStartOffsetCheckpoint}." +
+ s"is 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())
