cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From yu...@apache.org
Subject [2/3] git commit: Fix NPE when stream requestRanges
Date Tue, 06 May 2014 20:18:13 GMT
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 <josh.mckenzie@datastax.com>
Authored: Tue May 6 15:16:27 2014 -0500
Committer: Yuki Morishita <yukim@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++);


Mime
View raw message