Re: To run Apex runner of Apache Beam

Hi,  Thanks so much for helping so far!   I did want you guys said about setting the embedded execution to be false and remove the input arguments. Here is what I got: [ERROR] Failed to execute goal org.codehaus.mojo:exec-maven-plugin:1.5.0:java (default-cli) on project beam-examples-java: An

Re: To run Apex runner of Apache Beam

I guess that TfIdf example and/or apex runner can't handle local file system. Try using default input. java.lang.RuntimeException: java.io.FileNotFoundException: /Users/vrozov/Projects/Apache/beam/examples (Is a directory) at

Re: To run Apex runner of Apache Beam

It may also be helpful to enable logging to see if there are any exceptions in the execution. The console log only contains output from Maven. Is logging turned off (or a suitable slf4j backend missing)? On Fri, Jun 2, 2017 at 5:00 PM, Thomas Weise wrote: > Hi Claire, > > The

Re: To run Apex runner of Apache Beam

Hi Claire, The stack traces suggest that the application was launched and the Apex DAG is deployed and might be running (it runs in embedded mode). Do you see any output? In case it writes to files, anything in output or output staging directories? Thanks, Thomas On Thu, Jun 1, 2017 at 3:18

Re: To run Apex runner of Apache Beam

Hi Claire, Can you provide maven logs? It may also help to obtain stack trace. In a separate terminal window, run "jps -lv" and look for the jvm process id that executes org.apache.beam.examples.TfIdf. Use jstack to get the stack trace. Thank you, Vlad On 6/1/17 13:00, Claire Yuan wrote: