cassandra-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From slebre...@apache.org
Subject svn commit: r1152870 - in /cassandra/branches/cassandra-0.8: CHANGES.txt src/java/org/apache/cassandra/service/StorageService.java
Date Mon, 01 Aug 2011 17:33:36 GMT
Author: slebresne
Date: Mon Aug  1 17:33:35 2011
New Revision: 1152870

URL: http://svn.apache.org/viewvc?rev=1152870&view=rev
Log:
Ignore system tables during repair
patch by norman; reviewed by slebresne for CASSANDRA-2979

Modified:
    cassandra/branches/cassandra-0.8/CHANGES.txt
    cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageService.java

Modified: cassandra/branches/cassandra-0.8/CHANGES.txt
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/CHANGES.txt?rev=1152870&r1=1152869&r2=1152870&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.8/CHANGES.txt (original)
+++ cassandra/branches/cassandra-0.8/CHANGES.txt Mon Aug  1 17:33:35 2011
@@ -21,6 +21,7 @@
    with no post-flush activity permanently dirty) (CASSANDRA-2829)
  * fix throwing exception with batch mutation of counter super columns
    (CASSANDRA-2949)
+ * ignore system tables during repair (CASSANDRA-2979)
 
 
 0.8.2

Modified: cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageService.java
URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageService.java?rev=1152870&r1=1152869&r2=1152870&view=diff
==============================================================================
--- cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageService.java
(original)
+++ cassandra/branches/cassandra-0.8/src/java/org/apache/cassandra/service/StorageService.java
Mon Aug  1 17:33:35 2011
@@ -1532,6 +1532,11 @@ public class StorageService implements I
      */
     public void forceTableRepair(final String tableName, final String... columnFamilies)
throws IOException
     {
+        if (Table.SYSTEM_TABLE.equals(tableName)) 
+        {
+            return;
+        }
+        
         List<AntiEntropyService.RepairSession> sessions = new ArrayList<AntiEntropyService.RepairSession>();
         for (Range range : getLocalRanges(tableName))
         {



Mime
View raw message