cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From yu...@apache.org
Subject cassandra git commit: Fix wrong check when validating in parallel
Date Fri, 03 Apr 2015 20:44:11 GMT
Repository: cassandra
Updated Branches:
  refs/heads/trunk adcb8a439 -> 1dff098e4


Fix wrong check when validating in parallel

patch by yukim; reviewed by krummas for CASSANDRA-9099


Project: http://git-wip-us.apache.org/repos/asf/cassandra/repo
Commit: http://git-wip-us.apache.org/repos/asf/cassandra/commit/1dff098e
Tree: http://git-wip-us.apache.org/repos/asf/cassandra/tree/1dff098e
Diff: http://git-wip-us.apache.org/repos/asf/cassandra/diff/1dff098e

Branch: refs/heads/trunk
Commit: 1dff098e4c6d42b80ee05c7a444127752f112d08
Parents: adcb8a4
Author: Yuki Morishita <yukim@apache.org>
Authored: Thu Apr 2 10:08:10 2015 -0500
Committer: Yuki Morishita <yukim@apache.org>
Committed: Fri Apr 3 15:43:36 2015 -0500

----------------------------------------------------------------------
 src/java/org/apache/cassandra/db/compaction/CompactionManager.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/cassandra/blob/1dff098e/src/java/org/apache/cassandra/db/compaction/CompactionManager.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/cassandra/db/compaction/CompactionManager.java b/src/java/org/apache/cassandra/db/compaction/CompactionManager.java
index a3c3b9a..0e4ce0c 100644
--- a/src/java/org/apache/cassandra/db/compaction/CompactionManager.java
+++ b/src/java/org/apache/cassandra/db/compaction/CompactionManager.java
@@ -1027,7 +1027,7 @@ public class CompactionManager implements CompactionManagerMBean
 
                 for (SSTableReader sstable : sstableCandidates.sstables)
                 {
-                    if (!(new Bounds<>(sstable.first.getToken(), sstable.last.getToken()).intersects(Arrays.asList(validator.desc.range))))
+                    if (new Bounds<>(sstable.first.getToken(), sstable.last.getToken()).intersects(Collections.singletonList(validator.desc.range)))
                     {
                         sstablesToValidate.add(sstable);
                     }


Mime
View raw message