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

    https://github.com/apache/flink/pull/6147#discussion_r195035371
  
    --- Diff: 
flink-runtime/src/main/java/org/apache/flink/runtime/filecache/FileCache.java 
---
    @@ -342,4 +320,54 @@ public void run() {
                        }
                }
        }
    +
    +   public static Path compressDirectory(Path directory) throws IOException 
{
    --- End diff --
    
    If so, then we should also pass the target path to this method.


---

Reply via email to