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_ `=`
---