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?---
