Mailing-List: contact commits-help@beam.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@beam.apache.org
Date: Thu, 22 Dec 2016 01:42:58 +0000 (UTC)
From: "Pramod Immaneni (JIRA)" <jira@apache.org>
To: commits@beam.incubator.apache.org
Message-ID: <JIRA.13029969.1482370947000.577182.1482370978435@Atlassian.JIRA>
In-Reply-To: <JIRA.13029969.1482370947000@Atlassian.JIRA>
References: <JIRA.13029969.1482370947000@Atlassian.JIRA> <JIRA.13029969.1482370947848@arcas>
Subject: [jira] [Commented] (BEAM-1203) Exception when running apex runner
 in non embedded mode
MIME-Version: 1.0
Content-Type: text/plain; charset=utf-8
Content-Transfer-Encoding: 7bit
archived-at: Thu, 22 Dec 2016 01:43:02 -0000


    [ https://issues.apache.org/jira/browse/BEAM-1203?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15768718#comment-15768718 ] 

Pramod Immaneni commented on BEAM-1203:
---------------------------------------

I would like to look at it.

> Exception when running apex runner in non embedded mode
> -------------------------------------------------------
>
>                 Key: BEAM-1203
>                 URL: https://issues.apache.org/jira/browse/BEAM-1203
>             Project: Beam
>          Issue Type: Bug
>          Components: runner-apex
>    Affects Versions: 0.5.0-incubating
>            Reporter: Pramod Immaneni
>
> Tried to run the word count example application using apex runner on yarn with the command below (the command refers to local files so app when running will not be able to access these files but that is a different issue). There is an exception and the application does not get launched.
> mvn exec:java -Dexec.mainClass=org.apache.beam.examples.WordCount -Dexec.args="--inputFile=/home/pramod/Development/test/kinglear.txt --output=/home/pramod/Development/test/wordcounts.txt --runner=ApexRunner --embeddedExecution=false" -Papex-runner
> java.nio.file.FileAlreadyExistsException: META-INF/
> 	at com.sun.nio.zipfs.ZipFileSystem.createDirectory(ZipFileSystem.java:422)
> 	at com.sun.nio.zipfs.ZipPath.createDirectory(ZipPath.java:634)
> 	at com.sun.nio.zipfs.ZipFileSystemProvider.createDirectory(ZipFileSystemProvider.java:201)
> 	at java.nio.file.Files.createDirectory(Files.java:630)
> 	at org.apache.beam.runners.apex.ApexYarnLauncher$2.preVisitDirectory(ApexYarnLauncher.java:266)
> 	at org.apache.beam.runners.apex.ApexYarnLauncher$2.preVisitDirectory(ApexYarnLauncher.java:252)
> 	at java.nio.file.FileTreeWalker.walk(FileTreeWalker.java:192)
> 	at java.nio.file.FileTreeWalker.walk(FileTreeWalker.java:199)
> 	at java.nio.file.FileTreeWalker.walk(FileTreeWalker.java:69)
> 	at java.nio.file.Files.walkFileTree(Files.java:2602)
> 	at java.nio.file.Files.walkFileTree(Files.java:2635)
> 	at org.apache.beam.runners.apex.ApexYarnLauncher.createJar(ApexYarnLauncher.java:252)
> 	at org.apache.beam.runners.apex.ApexYarnLauncher.launchApp(ApexYarnLauncher.java:90)
> 	at org.apache.beam.runners.apex.ApexRunner.run(ApexRunner.java:149)
> 	at org.apache.beam.runners.apex.ApexRunner.run(ApexRunner.java:63)
> 	at org.apache.beam.sdk.Pipeline.run(Pipeline.java:176)
> 	at org.apache.beam.examples.WordCount.main(WordCount.java:184)
> 	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
> 	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 	at java.lang.reflect.Method.invoke(Method.java:606)
> 	at org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:293)
> 	at java.lang.Thread.run(Thread.java:745)


--
This message was sent by Atlassian JIRA
(v6.3.4#6332)