This is an automated email from the ASF dual-hosted git repository.

adelapena pushed a commit to branch cassandra-3.0
in repository https://gitbox.apache.org/repos/asf/cassandra.git


The following commit(s) were added to refs/heads/cassandra-3.0 by this push:
     new 8d71e06  Fix flaky test 
MigrationCoordinatorTest.testWeKeepSendingRequests not waiting for callback 
failure to complete before asserting that a new request has been sent
8d71e06 is described below

commit 8d71e06c1c83df5ec29069e3be3352f1dcf1d1d2
Author: Caleb Rackliffe <[email protected]>
AuthorDate: Tue Feb 16 17:20:48 2021 +0000

    Fix flaky test MigrationCoordinatorTest.testWeKeepSendingRequests not 
waiting for callback failure to complete before asserting that a new request 
has been sent
    
    patch by Caleb Rackliffe; reviewed by Andrés de la Peña for CASSANDRA-16450
---
 test/unit/org/apache/cassandra/service/MigrationCoordinatorTest.java | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git 
a/test/unit/org/apache/cassandra/service/MigrationCoordinatorTest.java 
b/test/unit/org/apache/cassandra/service/MigrationCoordinatorTest.java
index 070537d..6817e4f 100644
--- a/test/unit/org/apache/cassandra/service/MigrationCoordinatorTest.java
+++ b/test/unit/org/apache/cassandra/service/MigrationCoordinatorTest.java
@@ -56,7 +56,6 @@ public class MigrationCoordinatorTest
     private static final UUID LOCAL_VERSION = UUID.randomUUID();
     private static final UUID V1 = UUID.randomUUID();
     private static final UUID V2 = UUID.randomUUID();
-    private static final UUID V3 = UUID.randomUUID();
 
     static
     {
@@ -256,7 +255,7 @@ public class MigrationCoordinatorTest
     }
 
     @Test
-    public void testWeKeepSendingRequests()
+    public void testWeKeepSendingRequests() throws Exception
     {
         InstrumentedCoordinator coordinator = new InstrumentedCoordinator();
 
@@ -283,7 +282,7 @@ public class MigrationCoordinatorTest
                 Assert.fail(String.format("Not expecting prev %s to be equal 
to next %s", prev.endpoint, next.endpoint));
 
             // should send a new request
-            next.fail();
+            next.fail().get();
             prev = next;
             Assert.assertFalse(coordinator.awaitSchemaRequests(1));
 


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to