natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
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-24 08:14:45 +02:00
parent e8891be04a 5e4ff921af
commit 7446529e45
1 changed files with 15 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -24,6 +24,7 @@ import java.util.List;
import com.google.common.collect.Iterables;
import org.apache.cassandra.Util;
import org.apache.cassandra.repair.consistent.LocalSession;
import org.junit.Assert;
@ -353,7 +354,6 @@ public class CompactionStrategyManagerPendingRepairTest extends AbstractPendingR
LocalSessionAccessor.finalizeUnsafe(repairID);
LocalSession session = ARS.consistent.local.getSession(repairID);
ARS.consistent.local.sessionCompleted(session);
Assert.assertTrue(hasPendingStrategiesFor(repairID));
// run the compaction
if (compactionTask != null)
@ -364,7 +364,6 @@ public class CompactionStrategyManagerPendingRepairTest extends AbstractPendingR
// 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());
System.out.println("*********************************************************************************************");
System.out.println(compactedSSTable);
@ -380,9 +379,22 @@ public class CompactionStrategyManagerPendingRepairTest extends AbstractPendingR
{
Assert.assertSame(PendingRepairManager.RepairFinishedCompactionTask.class, compactionTask.getClass());
compactionTask.execute(ActiveCompactionsTracker.NOOP);
Assert.assertEquals(1, cfs.getLiveSSTables().size());
while ((compactionTask = csm.getNextBackgroundTask(FBUtilities.nowInSeconds())) != null)
compactionTask.execute(ActiveCompactionsTracker.NOOP);
}
// Make sure you consume all pending compactions
Util.spinAssertEquals(Boolean.FALSE,
() -> {
AbstractCompactionTask ctask;
while ((ctask = csm.getNextBackgroundTask(FBUtilities.nowInSeconds())) != null)
ctask.execute(ActiveCompactionsTracker.NOOP);
return hasPendingStrategiesFor(repairID);
},
30);
System.out.println("*********************************************************************************************");
System.out.println(compactedSSTable);
System.out.println("Pending repair UUID: " + compactedSSTable.getPendingRepair());