natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merge branch 'cassandra-5.0' into trunk 

* cassandra-5.0:
  Add extra compaction junit
This commit is contained in:
Bereng 2024-10-16 13:38:00 +02:00
parent 5e884a9329 38857dc047
commit f90a6ca388
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
test/unit/org/apache/cassandra/db/compaction/CompactionStrategyManagerPendingRepairTest.java
View File

@ -348,7 +348,6 @@ public class CompactionStrategyManagerPendingRepairTest extends AbstractPendingR
for (SSTableReader sstable : sstables)
pendingContains(sstable);
AbstractCompactionTask compactionTask = csm.getNextBackgroundTask(FBUtilities.nowInSeconds());
Assert.assertNotNull(compactionTask);
// Finalize the repair session
LocalSessionAccessor.finalizeUnsafe(repairID);
@ -357,12 +356,15 @@ public class CompactionStrategyManagerPendingRepairTest extends AbstractPendingR
Assert.assertTrue(hasPendingStrategiesFor(repairID));
// run the compaction
compactionTask.execute(ActiveCompactionsTracker.NOOP);
if (compactionTask != null)
{
compactionTask.execute(ActiveCompactionsTracker.NOOP);
Assert.assertEquals(1, cfs.getLiveSSTables().size());
}
// The repair session is finalized but there is an sstable left behind pending repair!
// The repair session is finalized but there could be an sstable left behind pending repair!
SSTableReader compactedSSTable = cfs.getLiveSSTables().iterator().next();
Assert.assertEquals(repairID, compactedSSTable.getPendingRepair());
Assert.assertEquals(1, cfs.getLiveSSTables().size());
System.out.println("*********************************************************************************************");
System.out.println(compactedSSTable);
@ -378,6 +380,7 @@ public class CompactionStrategyManagerPendingRepairTest extends AbstractPendingR
{
Assert.assertSame(PendingRepairManager.RepairFinishedCompactionTask.class, compactionTask.getClass());
compactionTask.execute(ActiveCompactionsTracker.NOOP);
Assert.assertEquals(1, cfs.getLiveSSTables().size());
}
System.out.println("*********************************************************************************************");
@ -388,7 +391,6 @@ public class CompactionStrategyManagerPendingRepairTest extends AbstractPendingR
System.out.println("Live sstables: " + cfs.getLiveSSTables().size());
System.out.println("*********************************************************************************************");
Assert.assertEquals(1, cfs.getLiveSSTables().size());
Assert.assertFalse(hasPendingStrategiesFor(repairID));
Assert.assertFalse(hasTransientStrategiesFor(repairID));
Assert.assertTrue(repairedContains(compactedSSTable));