kafka-950; Leader election rate may be reported on a non-controller; patched by Jun Rao; reviewed by Sriram Subramanian
Project: http://git-wip-us.apache.org/repos/asf/kafka/repo Commit: http://git-wip-us.apache.org/repos/asf/kafka/commit/5f14a69c Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/5f14a69c Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/5f14a69c Branch: refs/heads/trunk Commit: 5f14a69c2e5c21be9b1257e62040e89f400ac2d9 Parents: 5a084f7 Author: Jun Rao <jun...@gmail.com> Authored: Sun Jun 23 22:04:46 2013 -0700 Committer: Jun Rao <jun...@gmail.com> Committed: Sun Jun 23 22:04:46 2013 -0700 ---------------------------------------------------------------------- core/src/main/scala/kafka/log/LogSegment.scala | 1 + 1 file changed, 1 insertion(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/kafka/blob/5f14a69c/core/src/main/scala/kafka/log/LogSegment.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/kafka/log/LogSegment.scala b/core/src/main/scala/kafka/log/LogSegment.scala index 8cc1c94..6f11a8b 100644 --- a/core/src/main/scala/kafka/log/LogSegment.scala +++ b/core/src/main/scala/kafka/log/LogSegment.scala @@ -147,6 +147,7 @@ class LogSegment(val messageSet: FileMessageSet, messageSet.truncateTo(mapping.position) if (messageSet.sizeInBytes == 0) firstAppendTime = None + bytesSinceLastIndexEntry = 0 } /**
