Github user NicoK commented on a diff in the pull request: https://github.com/apache/flink/pull/4939#discussion_r149078183 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/Utils.java --- @@ -408,10 +437,12 @@ static ContainerLaunchContext createTaskExecutorContext( // prepare additional files to be shipped for (String pathStr : shipListString.split(",")) { if (!pathStr.isEmpty()) { + String[] pathWithKey = pathStr.split("="); --- End diff -- yes, if you see this as the order of the arguments in the array - I'll adapt the name
---