You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2015/12/01 20:50:24 UTC
kafka git commit: MINOR - fix typo in index corruption warning message
Repository: kafka
Updated Branches:
refs/heads/trunk 0264127ba -> 4649c347b
MINOR - fix typo in index corruption warning message
Author: Dong Lin <li...@gmail.com>
Reviewers: Ismael Juma, Guozhang Wang
Closes #606 from lindong28/minor-fix-typo
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/4649c347
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/4649c347
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/4649c347
Branch: refs/heads/trunk
Commit: 4649c347b6a59f8fbd4fcaf2363eb172a7da1d4c
Parents: 0264127
Author: Dong Lin <li...@gmail.com>
Authored: Tue Dec 1 11:50:21 2015 -0800
Committer: Guozhang Wang <wa...@gmail.com>
Committed: Tue Dec 1 11:50:21 2015 -0800
----------------------------------------------------------------------
core/src/main/scala/kafka/log/Log.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/4649c347/core/src/main/scala/kafka/log/Log.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/log/Log.scala b/core/src/main/scala/kafka/log/Log.scala
index 9667aaa..07164f6 100644
--- 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)
}