kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject kafka git commit: MINOR - fix typo in index corruption warning message
Date Tue, 01 Dec 2015 19:50:24 GMT
Repository: kafka
Updated Branches:
  refs/heads/trunk 0264127ba -> 4649c347b


MINOR - fix typo in index corruption warning message

Author: Dong Lin <lindong28@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 <lindong28@gmail.com>
Authored: Tue Dec 1 11:50:21 2015 -0800
Committer: Guozhang Wang <wangguoz@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)
           }


Mime
View raw message