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

Add extra compaction junit 

patch by Berenguer Blasi; reviewed by Branimir Lambov, Michael Semb Wever for CASSANDRA-19863
This commit is contained in:
Bereng 2024-10-22 14:27:49 +02:00
parent a58fa2ce7f
commit 5e4ff921af
1 changed files with 16 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
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;
@ -374,15 +375,29 @@ public class CompactionStrategyManagerPendingRepairTest extends AbstractPendingR
System.out.println("Live sstables: " + cfs.getLiveSSTables().size());
System.out.println("*********************************************************************************************");
// Run compaction again. It should pick up the pending repair sstable
compactionTask = csm.getNextBackgroundTask(FBUtilities.nowInSeconds());
if (compactionTask != null)
{
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());