Github user tillrohrmann commented on a diff in the pull request:
https://github.com/apache/flink/pull/5442#discussion_r168212886
--- Diff:
flink-runtime/src/main/java/org/apache/flink/runtime/rest/RestServerEndpointConfiguration.java
---
@@ -103,6 +126,9 @@ public static RestServerEndpointConfiguration
fromConfiguration(Configuration co
}
}
- return new RestServerEndpointConfiguration(address, port,
sslEngine);
+ final Path uploadDir =
Paths.get(config.getString(WebOptions.UPLOAD_DIR,
+ config.getString(WebOptions.TMP_DIR)));
--- End diff --
I think we should create a unique sub folder in order to avoid clashes
between concurrent processes on the same machine. Will do this when merging
this PR.
---
