diff --git a/src/java/org/apache/cassandra/config/CFMetaData.java b/src/java/org/apache/cassandra/config/CFMetaData.java index 2ed4a95617..607359451f 100644 --- a/src/java/org/apache/cassandra/config/CFMetaData.java +++ b/src/java/org/apache/cassandra/config/CFMetaData.java @@ -857,7 +857,7 @@ public final class CFMetaData { className = className.contains(".") ? className : "org.apache.cassandra.db.compaction." + className; Class strategyClass = FBUtilities.classForName(className, "compaction strategy"); - if (strategyClass.equals(WrappingCompactionStrategy.class)) + if (className.equals(WrappingCompactionStrategy.class.getName())) throw new ConfigurationException("You can't set WrappingCompactionStrategy as the compaction strategy!"); if (!AbstractCompactionStrategy.class.isAssignableFrom(strategyClass)) throw new ConfigurationException(String.format("Specified compaction strategy class (%s) is not derived from AbstractReplicationStrategy", className)); @@ -869,10 +869,8 @@ public final class CFMetaData { try { - Constructor constructor = compactionStrategyClass.getConstructor(new Class[] { - ColumnFamilyStore.class, - Map.class // options - }); + Constructor constructor = + compactionStrategyClass.getConstructor(ColumnFamilyStore.class, Map.class); return constructor.newInstance(cfs, compactionStrategyOptions); } catch (NoSuchMethodException | IllegalAccessException | InvocationTargetException | InstantiationException e)