This is an automated email from the ASF dual-hosted git repository. dwysakowicz pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 68512cc2cdc427a04659f3d243a2309416ba5eb7 Author: Dawid Wysakowicz <[email protected]> AuthorDate: Thu Apr 15 11:45:20 2021 +0200 [hotfix][tests] Cancel all running jobs after each test in AbstractTestBase --- .../java/org/apache/flink/test/util/AbstractTestBase.java | 15 +++++++++++++++ 1 file changed, 15 insertions(+) diff --git a/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/AbstractTestBase.java b/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/AbstractTestBase.java index dc66f22..6695bc9 100644 --- a/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/AbstractTestBase.java +++ b/flink-test-utils-parent/flink-test-utils/src/main/java/org/apache/flink/test/util/AbstractTestBase.java @@ -18,9 +18,11 @@ package org.apache.flink.test.util; +import org.apache.flink.runtime.client.JobStatusMessage; import org.apache.flink.runtime.testutils.MiniClusterResourceConfiguration; import org.apache.flink.util.FileUtils; +import org.junit.After; import org.junit.ClassRule; import org.junit.rules.TemporaryFolder; @@ -66,6 +68,19 @@ public abstract class AbstractTestBase extends TestBaseUtils { @ClassRule public static final TemporaryFolder TEMPORARY_FOLDER = new TemporaryFolder(); + @After + public final void cleanupRunningJobs() throws Exception { + for (JobStatusMessage path : miniClusterResource.getClusterClient().listJobs().get()) { + if (!path.getJobState().isTerminalState()) { + try { + miniClusterResource.getClusterClient().cancel(path.getJobId()).get(); + } catch (Exception ignored) { + // ignore exceptions when cancelling dangling jobs + } + } + } + } + // -------------------------------------------------------------------------------------------- // Temporary File Utilities // --------------------------------------------------------------------------------------------
