diff --git a/test/distributed/org/apache/cassandra/distributed/test/IncRepairCoordinatorErrorTest.java b/test/distributed/org/apache/cassandra/distributed/test/IncRepairCoordinatorErrorTest.java index c06e848399..447cd822e2 100644 --- a/test/distributed/org/apache/cassandra/distributed/test/IncRepairCoordinatorErrorTest.java +++ b/test/distributed/org/apache/cassandra/distributed/test/IncRepairCoordinatorErrorTest.java @@ -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); });