Fix for C* 2.1 when the dc collection and host collection are empty

thelastpickle · Nov 4, 2016 · d8039d3 · d8039d3
1 parent 6ad05b6
commit d8039d3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/src/main/java/com/spotify/reaper/cassandra/JmxProxy.java b/src/main/java/com/spotify/reaper/cassandra/JmxProxy.java
@@ -380,7 +380,7 @@ public int triggerRepair(BigInteger beginToken, BigInteger endToken, String keys
           if (repairParallelism.equals(RepairParallelism.DATACENTER_AWARE)) {
             if (canUseDatacenterAware) {
               return ((StorageServiceMBean) ssProxy).forceRepairRangeAsync(beginToken.toString(), endToken.toString(),
-                  keyspace, repairParallelism.ordinal(), new HashSet<String>(), new HashSet<String>(), fullRepair,
+                  keyspace, repairParallelism.ordinal(), cassandraVersion.startsWith("2.2")?new HashSet<String>():null, cassandraVersion.startsWith("2.2")?new HashSet<String>():null, fullRepair,
                   columnFamilies.toArray(new String[columnFamilies.size()]));
             } else {
               LOG.info("Cannot use DATACENTER_AWARE repair policy for Cassandra cluster with version {},"
@@ -392,7 +392,7 @@ public int triggerRepair(BigInteger beginToken, BigInteger endToken, String keys
 
           return ((StorageServiceMBean) ssProxy).forceRepairRangeAsync(beginToken.toString(), endToken.toString(),
               keyspace, snapshotRepair ? RepairParallelism.SEQUENTIAL.ordinal() : RepairParallelism.PARALLEL.ordinal(),
-              new HashSet<String>(), new HashSet<String>(), fullRepair,
+                  cassandraVersion.startsWith("2.2")?new HashSet<String>():null, cassandraVersion.startsWith("2.2")?new HashSet<String>():null, fullRepair,
               columnFamilies.toArray(new String[columnFamilies.size()]));
 
         } else {