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

Fix test/distributed/org/apache/cassandra/distributed/test/IncRepairCoordinatorErrorTest 

patch by Stefan Miklosovic; reviewed by Josh McKenzie for CASSANDRA-17843
This commit is contained in:
Stefan Miklosovic 2022-08-20 15:01:01 +02:00
parent 31b607c92a
commit f4deef9d58
1 changed files with 2 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -18,14 +18,13 @@
package org.apache.cassandra.distributed.test;
import java.util.UUID;
import org.junit.Test;
import org.apache.cassandra.distributed.Cluster;
import org.apache.cassandra.distributed.api.ConsistencyLevel;
import org.apache.cassandra.distributed.api.Feature;
import org.apache.cassandra.service.ActiveRepairService;
import org.apache.cassandra.utils.TimeUUID;
import static org.apache.cassandra.net.Verb.FINALIZE_COMMIT_MSG;
import static org.assertj.core.api.Assertions.assertThat;
@ -47,7 +46,7 @@ public class IncRepairCoordinatorErrorTest extends TestBaseImpl
.to(3)
.messagesMatching((from, to, msg) -> msg.verb() == FINALIZE_COMMIT_MSG.id).drop();
cluster.get(1).nodetoolResult("repair", KEYSPACE).asserts().success();
UUID result = (UUID) cluster.get(1).executeInternal("select parent_id from system_distributed.repair_history")[0][0];
TimeUUID result = (TimeUUID) cluster.get(1).executeInternal("select parent_id from system_distributed.repair_history")[0][0];
cluster.get(3).runOnInstance(() -> {
ActiveRepairService.instance.failSession(result.toString(), true);
});