root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 4 Packages Projects Releases Wiki Activity

MINOR: Fix typo in Log.scala: "actually recovery" > "actually recover" (#4440)

This commit is contained in:
Jeff Widman 2018-01-18 14:36:20 -08:00 committed by Jason Gustafson
parent 70f25b9519
commit ae6cb15f5f
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
core/src/main/scala/kafka/log/Log.scala
View File

@ -425,7 +425,7 @@ class Log(@volatile var dir: File,
private def recoverLog(): Long = {
// if we have the clean shutdown marker, skip recovery
if (!hasCleanShutdownFile) {
// okay we need to actually recovery this log
// okay we need to actually recover this log
val unflushed = logSegments(this.recoveryPoint, Long.MaxValue).iterator
while (unflushed.hasNext) {
val segment = unflushed.next