[flink] branch master updated: [hotfix][tests] Delete tmp directory after cluster has shut down

[chesnay]

This is an automated email from the ASF dual-hosted git repository.

chesnay pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 7a4b1c0  [hotfix][tests] Delete tmp directory after cluster has shut 
down
7a4b1c0 is described below

commit 7a4b1c064f9adf7de29d63a47363b4ceba141c0e
Author: Chesnay Schepler <ches...@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 {