Re: To run Apex runner of Apache Beam

[Vlad Rozov]

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:

Hi,
  I am using the Apex runner to execute Apache Beam example pipeline. 
However my terminal always get frozen when running the command:
|mvn compile exec:java -Dexec.mainClass=org.apache.beam.examples.TfIdf 
\ -Dexec.args="--inputFile=pom.xml --output=counts 
--runner=ApexRunner" -Papex-runner|

  Would anyone have solution for this?

Claire

Re: Hdfs + apex-core

[userguy]

I am attaching code and ERROR when we try to consume from multiple topic 

kafka2hdfs.zip
  
kafkalog.txt
  




--
View this message in context: 
http://apache-apex-users-list.78494.x6.nabble.com/Fwd-Hdfs-apex-core-tp1608p1669.html
Sent from the Apache Apex Users list mailing list archive at Nabble.com.