Repository: kafka
Updated Branches:
refs/heads/0.8.2 5e071cd25 -> 9be9a80d0
KAFKA-1732 DumpLogSegments tool fails when path has a '.'; reviewed by Neha Narkhede
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo
Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/9be9a80d
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/9be9a80d
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/9be9a80d
Branch: refs/heads/0.8.2
Commit: 9be9a80d0c794efb0be9a23908b286e1650f6a95
Parents: 5e071cd
Author: Ewen Cheslack-Postava <me@ewencp.org>
Authored: Mon Oct 27 16:24:34 2014 -0700
Committer: Neha Narkhede <neha.narkhede@gmail.com>
Committed: Mon Oct 27 16:24:38 2014 -0700
----------------------------------------------------------------------
core/src/main/scala/kafka/tools/DumpLogSegments.scala | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/kafka/blob/9be9a80d/core/src/main/scala/kafka/tools/DumpLogSegments.scala
----------------------------------------------------------------------
diff --git a/core/src/main/scala/kafka/tools/DumpLogSegments.scala b/core/src/main/scala/kafka/tools/DumpLogSegments.scala
index 8e9d47b..fe2cc11 100644
--- a/core/src/main/scala/kafka/tools/DumpLogSegments.scala
+++ b/core/src/main/scala/kafka/tools/DumpLogSegments.scala
@@ -104,8 +104,7 @@ object DumpLogSegments {
misMatchesForIndexFilesMap: mutable.HashMap[String, List[(Long, Long)]],
maxMessageSize: Int) {
val startOffset = file.getName().split("\\.")(0).toLong
- val logFileName = file.getAbsolutePath.split("\\.")(0) + Log.LogFileSuffix
- val logFile = new File(logFileName)
+ val logFile = new File(file.getAbsoluteFile.getParent, file.getName.split("\\.")(0) +
Log.LogFileSuffix)
val messageSet = new FileMessageSet(logFile, false)
val index = new OffsetIndex(file = file, baseOffset = startOffset)
for(i <- 0 until index.entries) {
|