You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tr...@apache.org on 2017/10/20 12:41:53 UTC
flink git commit: [FLINK-7875] [flip6] Start StaticFileServerHandler
with random tmp dir
Repository: flink
Updated Branches:
refs/heads/master a5801d058 -> 142ff78c3
[FLINK-7875] [flip6] Start StaticFileServerHandler with random tmp dir
This closes #4861.
Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/142ff78c
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/142ff78c
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/142ff78c
Branch: refs/heads/master
Commit: 142ff78c3851e9393d9c4d5ef1c65798c3dbdd21
Parents: a5801d0
Author: Till <ti...@gmail.com>
Authored: Thu Oct 19 13:51:55 2017 +0200
Committer: Till <ti...@gmail.com>
Committed: Fri Oct 20 14:41:29 2017 +0200
----------------------------------------------------------------------
.../flink/runtime/rest/handler/RestHandlerConfiguration.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/142ff78c/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/RestHandlerConfiguration.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/RestHandlerConfiguration.java b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/RestHandlerConfiguration.java
index 0344597..06d71f8 100644
--- a/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/RestHandlerConfiguration.java
+++ b/flink-runtime/src/main/java/org/apache/flink/runtime/rest/handler/RestHandlerConfiguration.java
@@ -24,6 +24,7 @@ import org.apache.flink.configuration.WebOptions;
import org.apache.flink.util.Preconditions;
import java.io.File;
+import java.util.UUID;
/**
* Configuration object containing values for the rest handler configuration.
@@ -75,7 +76,8 @@ public class RestHandlerConfiguration {
final Time timeout = Time.milliseconds(configuration.getLong(WebOptions.TIMEOUT));
- final File tmpDir = new File(configuration.getString(WebOptions.TMP_DIR));
+ final String rootDir = "flink-web-" + UUID.randomUUID();
+ final File tmpDir = new File(configuration.getString(WebOptions.TMP_DIR), rootDir);
return new RestHandlerConfiguration(refreshInterval, maxCheckpointStatisticCacheEntries, timeout, tmpDir);
}