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

dwysakowicz pushed a commit to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.15 by this push:
     new b6d5758  [FLINK-26418][runtime][test] Use java.io.tmpdir for 
tmpWorkingDir
b6d5758 is described below

commit b6d57585bd4cab4183dd4197aef75fea17537f5a
Author: Marios Trivyzas <[email protected]>
AuthorDate: Wed Mar 9 19:45:18 2022 +0200

    [FLINK-26418][runtime][test] Use java.io.tmpdir for tmpWorkingDir
    
    Previously, the tmpWorkingDirectory was created in the current working
    directory, and as a result there were directories created in the root
    directories of the modules, i.e. `flink-table/flink-table-planner` which
    were not cleaned up with `mvn clean`.
---
 .../apache/flink/runtime/util/TestingTaskManagerRuntimeInfo.java   | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git 
a/flink-runtime/src/test/java/org/apache/flink/runtime/util/TestingTaskManagerRuntimeInfo.java
 
b/flink-runtime/src/test/java/org/apache/flink/runtime/util/TestingTaskManagerRuntimeInfo.java
index ac40230..739716f 100644
--- 
a/flink-runtime/src/test/java/org/apache/flink/runtime/util/TestingTaskManagerRuntimeInfo.java
+++ 
b/flink-runtime/src/test/java/org/apache/flink/runtime/util/TestingTaskManagerRuntimeInfo.java
@@ -38,7 +38,8 @@ public class TestingTaskManagerRuntimeInfo implements 
TaskManagerRuntimeInfo {
     public TestingTaskManagerRuntimeInfo() {
         this(
                 new Configuration(),
-                System.getProperty("java.io.tmpdir").split(",|" + 
File.pathSeparator));
+                EnvironmentInformation.getTemporaryFileDirectory()
+                        .split(",|" + File.pathSeparator));
     }
 
     public TestingTaskManagerRuntimeInfo(Configuration configuration) {
@@ -62,7 +63,9 @@ public class TestingTaskManagerRuntimeInfo implements 
TaskManagerRuntimeInfo {
                 configuration,
                 tmpDirectories,
                 InetAddress.getLoopbackAddress().getHostAddress(),
-                new File("tmp_" + UUID.randomUUID()));
+                new File(
+                        EnvironmentInformation.getTemporaryFileDirectory(),
+                        "tmp_" + UUID.randomUUID()));
     }
 
     public TestingTaskManagerRuntimeInfo(

Reply via email to