Github user JTaky commented on a diff in the pull request: https://github.com/apache/flink/pull/6284#discussion_r202755897 --- 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 + } + ContainerLaunchContext taskExecutorLaunchContext = Utils.createTaskExecutorContext( - flinkConfig, --- End diff -- done. Thank you very much! Since you seem fine with this hacky approach I have tested and made stable the last PR on our Yarn cluster.
---