diff --git a/java/integTest/src/test/java/glide/cluster/CommandTests.java b/java/integTest/src/test/java/glide/cluster/CommandTests.java index 8ab25d34e1..080655a624 100644 --- a/java/integTest/src/test/java/glide/cluster/CommandTests.java +++ b/java/integTest/src/test/java/glide/cluster/CommandTests.java @@ -1253,6 +1253,7 @@ public void functionStats_and_functionKill_without_route() { } assertEquals(OK, clusterClient.functionKill().get()); + Thread.sleep(404); // sometimes kill doesn't happen immediately exception = assertThrows(ExecutionException.class, () -> clusterClient.functionKill().get()); @@ -1339,7 +1340,7 @@ public void functionStats_and_functionKill_with_route(boolean singleNodeRoute) { // redis kills a function with 5 sec delay assertEquals(OK, clusterClient.functionKill(route).get()); - Thread.sleep(404); + Thread.sleep(404); // sometimes kill doesn't happen immediately exception = assertThrows(ExecutionException.class, () -> clusterClient.functionKill(route).get()); @@ -1410,6 +1411,7 @@ public void functionStats_and_functionKill_with_key_based_route() { // redis kills a function with 5 sec delay assertEquals(OK, clusterClient.functionKill(route).get()); + Thread.sleep(404); // sometimes kill doesn't happen immediately exception = assertThrows(ExecutionException.class, () -> clusterClient.functionKill(route).get()); diff --git a/java/integTest/src/test/java/glide/standalone/CommandTests.java b/java/integTest/src/test/java/glide/standalone/CommandTests.java index 42bc850322..9f84cdfb27 100644 --- a/java/integTest/src/test/java/glide/standalone/CommandTests.java +++ b/java/integTest/src/test/java/glide/standalone/CommandTests.java @@ -604,6 +604,7 @@ public void functionStats_and_functionKill() { // redis kills a function with 5 sec delay assertEquals(OK, regularClient.functionKill().get()); + Thread.sleep(404); // sometimes kill doesn't happen immediately exception = assertThrows(ExecutionException.class, () -> regularClient.functionKill().get());