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

    https://github.com/apache/flink/pull/6296#discussion_r201586679
  
    --- 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 --
    
    there's still a space missing _after_ `=`


---

Reply via email to