mirror of https://github.com/apache/cassandra
Merge branch 'cassandra-2.1' into trunk
This commit is contained in:
commit
10b8a765be
|
|
@ -55,6 +55,8 @@
|
||||||
|
|
||||||
|
|
||||||
2.1.3
|
2.1.3
|
||||||
|
* Make sure we don't add tmplink files to the compaction
|
||||||
|
strategy (CASSANDRA-8580)
|
||||||
* (cqlsh) Handle maps with blob keys (CASSANDRA-8372)
|
* (cqlsh) Handle maps with blob keys (CASSANDRA-8372)
|
||||||
* (cqlsh) Handle DynamicCompositeType schemas correctly (CASSANDRA-8563)
|
* (cqlsh) Handle DynamicCompositeType schemas correctly (CASSANDRA-8563)
|
||||||
* Add tooling to detect hot partitions (CASSANDRA-7974)
|
* Add tooling to detect hot partitions (CASSANDRA-7974)
|
||||||
|
|
|
||||||
|
|
@ -323,10 +323,13 @@ public final class WrappingCompactionStrategy extends AbstractCompactionStrategy
|
||||||
super.startup();
|
super.startup();
|
||||||
for (SSTableReader sstable : cfs.getSSTables())
|
for (SSTableReader sstable : cfs.getSSTables())
|
||||||
{
|
{
|
||||||
if (sstable.isRepaired())
|
if (sstable.openReason != SSTableReader.OpenReason.EARLY)
|
||||||
repaired.addSSTable(sstable);
|
{
|
||||||
else
|
if (sstable.isRepaired())
|
||||||
unrepaired.addSSTable(sstable);
|
repaired.addSSTable(sstable);
|
||||||
|
else
|
||||||
|
unrepaired.addSSTable(sstable);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
repaired.startup();
|
repaired.startup();
|
||||||
unrepaired.startup();
|
unrepaired.startup();
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue