You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ro...@apache.org on 2021/11/12 21:15:41 UTC
[flink] 02/02: [FLINK-22419] Wait unlimited in
RpcEndpointTest.testCallAsyncTimeout
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 <kh...@gmail.com>
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);
}
}