Repository: incubator-beam Updated Branches: refs/heads/master 7984fe3fc -> aebe06756
BEAM-1203 Fixed exception when creating zip entries during Apex YARN launch Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/50b192dc Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/50b192dc Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/50b192dc Branch: refs/heads/master Commit: 50b192dcd80f52621ea252f60d62e91626a89596 Parents: 7984fe3 Author: Pramod Immaneni <[email protected]> Authored: Wed Dec 21 17:56:55 2016 -0800 Committer: Pramod Immaneni <[email protected]> Committed: Wed Dec 21 17:56:55 2016 -0800 ---------------------------------------------------------------------- .../java/org/apache/beam/runners/apex/ApexYarnLauncher.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/50b192dc/runners/apex/src/main/java/org/apache/beam/runners/apex/ApexYarnLauncher.java ---------------------------------------------------------------------- diff --git a/runners/apex/src/main/java/org/apache/beam/runners/apex/ApexYarnLauncher.java b/runners/apex/src/main/java/org/apache/beam/runners/apex/ApexYarnLauncher.java index 0ae4cc7..a2d88f4 100644 --- a/runners/apex/src/main/java/org/apache/beam/runners/apex/ApexYarnLauncher.java +++ b/runners/apex/src/main/java/org/apache/beam/runners/apex/ApexYarnLauncher.java @@ -260,8 +260,10 @@ public class ApexYarnLauncher { if (!relativePath.endsWith("/")) { relativePath += "/"; } - final Path dstDir = zipfs.getPath(relativePath); - Files.createDirectory(dstDir); + if (!relativePath.equals("META-INF/")) { + final Path dstDir = zipfs.getPath(relativePath); + Files.createDirectory(dstDir); + } } return super.preVisitDirectory(dir, attrs); }
