You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ch...@apache.org on 2019/07/24 11:26:39 UTC
[flink] branch release-1.9 updated: [hotfix][tests] Delete tmp
directory after cluster has shut down
This is an automated email from the ASF dual-hosted git repository.
chesnay pushed a commit to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.9 by this push:
new 6980293 [hotfix][tests] Delete tmp directory after cluster has shut down
6980293 is described below
commit 6980293401d354bff32c775e38b433b4a9972e26
Author: Chesnay Schepler <ch...@apache.org>
AuthorDate: Wed Jul 24 13:25:52 2019 +0200
[hotfix][tests] Delete tmp directory after cluster has shut down
---
.../java/org/apache/flink/runtime/testutils/MiniClusterResource.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/testutils/MiniClusterResource.java b/flink-runtime/src/test/java/org/apache/flink/runtime/testutils/MiniClusterResource.java
index 1aa4798..eb63ceb 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/testutils/MiniClusterResource.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/testutils/MiniClusterResource.java
@@ -94,8 +94,6 @@ public class MiniClusterResource extends ExternalResource {
@Override
public void after() {
- temporaryFolder.delete();
-
Exception exception = null;
if (miniCluster != null) {
@@ -147,6 +145,8 @@ public class MiniClusterResource extends ExternalResource {
if (exception != null) {
log.warn("Could not properly shut down the MiniClusterResource.", exception);
}
+
+ temporaryFolder.delete();
}
private void startMiniCluster() throws Exception {