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

    https://github.com/apache/flink/pull/6147#discussion_r195035257
  
    --- 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 --
    
    Should we move these methods rather in the `FileUtils` class as generic 
convenience methods?


---

Reply via email to