MINOR - fix typo in index corruption warning message

Author: Dong Lin <[email protected]> Reviewers: Ismael Juma, Guozhang Wang Closes apache#606 from lindong28/minor-fix-typo
fxenik · Dec 1, 2015 · 4649c34 · 4649c34
1 parent 0264127
commit 4649c34
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/main/scala/kafka/log/Log.scala b/core/src/main/scala/kafka/log/Log.scala
@@ -183,7 +183,7 @@ class Log(val dir: File,
               segment.index.sanityCheck()
           } catch {
             case e: java.lang.IllegalArgumentException =>
-              warn("Found an corrupted index file, %s, deleting and rebuilding index...".format(indexFile.getAbsolutePath))
+              warn("Found a corrupted index file, %s, deleting and rebuilding index...".format(indexFile.getAbsolutePath))
               indexFile.delete()
               segment.recover(config.maxMessageSize)
           }