[GitHub] flink pull request #6296: 解决flink-dist*.jar多次上ä¼

[linjun007]

Github user linjun007 commented on a diff in the pull request:

    https://github.com/apache/flink/pull/6296#discussion_r201543969
  
    --- Diff: 
flink-yarn/src/main/java/org/apache/flink/yarn/AbstractYarnClusterDescriptor.java
 ---
    @@ -1189,9 +1189,9 @@ private static Path setupSingleLocalResource(
                                        @Override
                                        public FileVisitResult 
visitFile(java.nio.file.Path file, BasicFileAttributes attrs)
                                                throws IOException {
    -
    -                                           if 
(!(file.getFileName().startsWith("flink-dist") &&
    -                                                           
file.getFileName().endsWith("jar"))) {
    +                                           String 
fileName=file.getFileName().toString();
    --- End diff --
    
    ok


---