beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhalp...@apache.org
Subject [2/5] incubator-beam git commit: BEAM-1203 Fixed exception when creating zip entries during Apex YARN launch
Date Thu, 22 Dec 2016 23:34:53 GMT
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/07a07280
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/07a07280
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/07a07280

Branch: refs/heads/python-sdk
Commit: 07a07280f0adc0b83476665733306c49d05f93ad
Parents: 99c49b0
Author: Pramod Immaneni <pramod@datatorrent.com>
Authored: Wed Dec 21 17:56:55 2016 -0800
Committer: Dan Halperin <dhalperi@google.com>
Committed: Thu Dec 22 15:34:41 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/07a07280/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);
         }


Mime
View raw message