kafka-commits mailing list archives

Updated Branches:
  refs/heads/trunk b61d147fd -> 0198e67fe


KAFKA-1042 follow up compilation fix; 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/0198e67f
Tree: http://git-wip-us.apache.org/repos/asf/kafka/tree/0198e67f
Diff: http://git-wip-us.apache.org/repos/asf/kafka/diff/0198e67f

Branch: refs/heads/trunk
Commit: 0198e67febfa805b7a5d7ef8a939254bbe0b0d00
Parents: b61d147
Author: Joris Van Remoortere <joris.van.remoortere@gmail.com>
Authored: Mon Oct 21 11:14:31 2013 -0700
Committer: Neha Narkhede <neha.narkhede@gmail.com>
Committed: Mon Oct 21 11:15:28 2013 -0700

----------------------------------------------------------------------
 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/0198e67f/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 008cc55..8cd489e 100644
--- a/core/src/main/scala/kafka/log/Log.scala
+++ b/core/src/main/scala/kafka/log/Log.scala
@@ -601,7 +601,7 @@ class Log(val dir: File,
       if(floor eq null)
         asIterable(segments.headMap(to).values)
       else
-        asIterable(segments.subMap(floor, true, to, false).values)
+        asIterable(segments.subMap(floor.longValue, true, to, false).values)
     }
   }