You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ma...@apache.org on 2022/03/10 14:16:16 UTC
[flink] 01/03: [hotfix][runtime] Adds missing @ExtendWith to DefaultResourceCleanerTest
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 <ma...@ververica.com>
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