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

Wait for move to finish before cleanup in TransientRangeMovement2Test#testMoveForward 

Patch by marcuse; reviewed by Sam Tunnicliffe for CASSANDRA-19803
This commit is contained in:
Marcus Eriksson 2024-07-31 15:33:07 +02:00
parent 9679206f74
commit 86a353b443
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
test/distributed/org/apache/cassandra/distributed/test/TransientRangeMovement2Test.java
View File

@ -118,7 +118,8 @@ public class TransientRangeMovement2Test extends TestBaseImpl
// pausing + cleanup in.
Callable<Epoch> pending = pauseBeforeCommit(cluster.get(1), (e) -> e instanceof PrepareMove.MidMove);
new Thread(() -> cluster.get(1).nodetoolResult("move", "15").asserts().success()).start();
Thread t = new Thread(() -> cluster.get(1).nodetoolResult("move", "15").asserts().success());
t.start();
Epoch pauseBeforeEnacting = pending.call().nextEpoch();
Callable<?> beforeEnacted = pauseBeforeEnacting(cluster.get(3), pauseBeforeEnacting);
@ -130,7 +131,7 @@ public class TransientRangeMovement2Test extends TestBaseImpl
unpauseEnactment(cluster.get(3));
waitForCMSToQuiesce(cluster, cluster.get(1));
t.join();
cluster.forEach(i -> i.nodetoolResult("cleanup").asserts().success());
assertAllContained(localStrs(cluster.get(1)),
newArrayList("22", "24", "26", "28", "30"),