You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by yu...@apache.org on 2014/05/06 22:18:13 UTC
[2/3] git commit: Fix NPE when stream requestRanges
Fix NPE when stream requestRanges
Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/60faac43
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/60faac43
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/60faac43
Branch: refs/heads/trunk
Commit: 60faac4340d959f9ce100430c84e1d26f7aa28af
Parents: ef92bb5
Author: Joshua McKenzie <jo...@datastax.com>
Authored: Tue May 6 15:16:27 2014 -0500
Committer: Yuki Morishita <yu...@apache.org>
Committed: Tue May 6 15:16:27 2014 -0500
----------------------------------------------------------------------
src/java/org/apache/cassandra/streaming/StreamCoordinator.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/cassandra/blob/60faac43/src/java/org/apache/cassandra/streaming/StreamCoordinator.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/streaming/StreamCoordinator.java b/src/java/org/apache/cassandra/streaming/StreamCoordinator.java
index 425b5b1..ed94f89 100644
--- a/src/java/org/apache/cassandra/streaming/StreamCoordinator.java
+++ b/src/java/org/apache/cassandra/streaming/StreamCoordinator.java
@@ -223,7 +223,7 @@ public class StreamCoordinator
// get
else
{
- if (lastReturned == streamSessions.size() - 1)
+ if (lastReturned >= streamSessions.size() - 1)
lastReturned = 0;
return streamSessions.get(lastReturned++);