This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.12 in repository https://gitbox.apache.org/repos/asf/flink.git
commit c1f8e731c8cb35c2e8a8b1294adc30312eac5349 Author: Roman Khachatryan <[email protected]> AuthorDate: Fri Nov 12 12:53:46 2021 +0100 [FLINK-22419] Wait unlimited in RpcEndpointTest.testCallAsyncTimeout --- .../src/test/java/org/apache/flink/runtime/rpc/RpcEndpointTest.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/RpcEndpointTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/RpcEndpointTest.java index 204fe2a..787db95 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/RpcEndpointTest.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/rpc/RpcEndpointTest.java @@ -376,13 +376,14 @@ public class RpcEndpointTest extends TestLogger { throws InterruptedException, ExecutionException, TimeoutException { final RpcEndpoint endpoint = new BaseEndpoint(rpcService); final Time timeout = Time.milliseconds(100); + CountDownLatch latch = new CountDownLatch(1); try { endpoint.start(); final CompletableFuture<Throwable> throwableFuture = endpoint.callAsync( () -> { endpoint.validateRunsInMainThread(); - TimeUnit.MILLISECONDS.sleep(timeout.toMilliseconds() * 2); + latch.await(); return 12345; }, timeout) @@ -392,6 +393,7 @@ public class RpcEndpointTest extends TestLogger { assertNotNull(throwable); assertThat(throwable, instanceOf(TimeoutException.class)); } finally { + latch.countDown(); RpcUtils.terminateRpcEndpoint(endpoint, TIMEOUT); } }
