This is an automated email from the ASF dual-hosted git repository. mapohl pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit dbae7aefb2111a4805f9aecbbd3ba2422e353531 Author: Matthias Pohl <[email protected]> AuthorDate: Mon Sep 12 11:37:07 2022 +0200 [hotfix][tests] Cleaned up JDK/assertj plugin warnings --- .../dispatcher/DefaultJobManagerRunnerRegistryTest.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DefaultJobManagerRunnerRegistryTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DefaultJobManagerRunnerRegistryTest.java index cce8ba21357..be48235d7e8 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DefaultJobManagerRunnerRegistryTest.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/DefaultJobManagerRunnerRegistryTest.java @@ -101,9 +101,9 @@ public class DefaultJobManagerRunnerRegistryTest { @Test public void size() { - assertThat(testInstance.size()).isEqualTo(0); + assertThat(testInstance.size()).isZero(); testInstance.register(TestingJobManagerRunner.newBuilder().build()); - assertThat(testInstance.size()).isEqualTo(1); + assertThat(testInstance.size()).isOne(); testInstance.register(TestingJobManagerRunner.newBuilder().build()); assertThat(testInstance.size()).isEqualTo(2); } @@ -134,7 +134,7 @@ public class DefaultJobManagerRunnerRegistryTest { } @Test - public void testSuccessfulLocalCleanup() throws Throwable { + public void testSuccessfulLocalCleanup() { final TestingJobManagerRunner jobManagerRunner = registerTestingJobManagerRunner(); assertThat( @@ -168,7 +168,7 @@ public class DefaultJobManagerRunnerRegistryTest { } @Test - public void testSuccessfulLocalCleanupAsync() throws Exception { + public void testSuccessfulLocalCleanupAsync() { final TestingJobManagerRunner jobManagerRunner = registerTestingJobManagerRunner(); final CompletableFuture<Void> cleanupResult = @@ -179,7 +179,7 @@ public class DefaultJobManagerRunnerRegistryTest { } @Test - public void testFailingLocalCleanupAsync() throws Exception { + public void testFailingLocalCleanupAsync() { final TestingJobManagerRunner jobManagerRunner = registerTestingJobManagerRunner(); assertThat(testInstance.isRegistered(jobManagerRunner.getJobID())).isTrue();
