Github user tillrohrmann commented on a diff in the pull request: https://github.com/apache/flink/pull/6284#discussion_r202087890 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/YarnResourceManager.java --- @@ -473,8 +474,13 @@ private ContainerLaunchContext createTaskExecutorLaunchContext(Resource resource log.debug("TaskManager configuration: {}", flinkConfig); + Configuration taskManagerConfig = flinkConfig.clone(); + if (!flinkConfig.containsKey(CoreOptions.TMP_DIRS_OVERRIDDEN)){ + taskManagerConfig.setString(CoreOptions.TMP_DIRS, ""); // HACK: emulate removal for the given key + } --- End diff -- Replace with `BootstratpTools#cloneConfiguration(Configuration)` in order to reduce code duplication.
---