This is an automated email from the ASF dual-hosted git repository. roman pushed a commit to branch release-1.14 in repository https://gitbox.apache.org/repos/asf/flink.git
commit 99bb454485153a4943bf987c1e35a4dfa8cbbd98 Author: Roman Khachatryan <[email protected]> AuthorDate: Fri Nov 12 12:53:02 2021 +0100 [hotfix][tests] Make RpcEndpointTest more informative --- .../java/org/apache/flink/runtime/rpc/RpcEndpointTest.java | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) 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 87a18f7..abd020f 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 @@ -35,10 +35,11 @@ import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import java.util.function.BiConsumer; +import static org.hamcrest.CoreMatchers.instanceOf; import static org.hamcrest.CoreMatchers.is; import static org.junit.Assert.assertEquals; +import static org.junit.Assert.assertNotNull; import static org.junit.Assert.assertThat; -import static org.junit.Assert.assertTrue; import static org.junit.Assert.fail; /** Tests for the RpcEndpoint, its self gateways and MainThreadExecutor scheduling command. */ @@ -371,9 +372,10 @@ public class RpcEndpointTest extends TestLogger { }, timeout) .handle((ignore, throwable) -> throwable); - final Throwable throwable = - throwableFuture.get(timeout.getSize() * 2, timeout.getUnit()); - assertTrue(throwable instanceof TimeoutException); + final Throwable throwable = throwableFuture.get(); + + assertNotNull(throwable); + assertThat(throwable, instanceOf(TimeoutException.class)); } finally { RpcUtils.terminateRpcEndpoint(endpoint, TIMEOUT); }
