Hi,
Just tried with one of my sample, and it runs fine locally (tried flink, spark
and direct). Let me try the quickstart tfidf example.
Regards
JB
On 05/23/2017 11:56 PM, Claire Yuan wrote:
To who may concern,
I am trying to run the Apache Beam with Java SDK on my computer. I already
cloned the codes from github and was trying to run the example in "TfIdf". When
I opened in IntelliJ and tried right click on it to run the main() in TfIdf, it
says :
Error: Could not find or load main class org.apache.beam.examples.complete.TfIdf
Also when I tried using the command I found in quickstart and run it in the
folder containing src codes for examples:
|mvn compile exec:java -Dexec.mainClass=org.apache.beam.examples.TfIdf \
-Dexec.args="--runner=FlinkRunner --inputFile=pom.xml --output=counts"
-Pflink-runner|
It stuck on the terminal. I am wondering if anyone could help in how to run
program locally in Ubuntu.
Sincerely, a user
--
Jean-Baptiste Onofré
[email protected]
http://blog.nanthrax.net
Talend - http://www.talend.com