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 f0fe63ee0ba1983f5a4204f4e55d8961d8465743 Author: Matthias Pohl <[email protected]> AuthorDate: Sun Mar 6 16:34:49 2022 +0100 [hotfix][runtime] Adds missing @ExtendWith to DefaultResourceCleanerTest --- .../flink/runtime/dispatcher/cleanup/DefaultResourceCleanerTest.java | 3 +++ 1 file changed, 3 insertions(+) diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/cleanup/DefaultResourceCleanerTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/cleanup/DefaultResourceCleanerTest.java index 36fef1c..df16df7 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/cleanup/DefaultResourceCleanerTest.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/dispatcher/cleanup/DefaultResourceCleanerTest.java @@ -22,11 +22,13 @@ import org.apache.flink.api.common.JobID; import org.apache.flink.core.testutils.FlinkAssertions; import org.apache.flink.runtime.concurrent.ComponentMainThreadExecutorServiceAdapter; import org.apache.flink.util.Preconditions; +import org.apache.flink.util.TestLoggerExtension; import org.apache.flink.util.concurrent.Executors; import org.apache.flink.util.concurrent.FutureUtils; import org.apache.flink.util.concurrent.RetryStrategy; import org.junit.jupiter.api.Test; +import org.junit.jupiter.api.extension.ExtendWith; import java.time.Duration; import java.util.ArrayList; @@ -42,6 +44,7 @@ import static org.apache.flink.core.testutils.FlinkAssertions.STREAM_THROWABLE; import static org.assertj.core.api.Assertions.assertThat; /** {@code DefaultResourceCleanerTest} tests {@link DefaultResourceCleaner}. */ +@ExtendWith(TestLoggerExtension.class) public class DefaultResourceCleanerTest { // runs with retry utilizes the ComponentMainThreadExecutor which adds concurrency despite using
