Hi Claire, Have you seen the Quickstarts on https://beam.apache.org? Specifically, we hope that https://beam.apache.org/get-started/quickstart-java/ answers these questions and has explicit instructions for running WordCount on all runners.
Dan On Wed, May 24, 2017 at 2:45 PM, Thomas Groh <[email protected]> wrote: > You should specify the Flink profile when you execute, with > '-Pflink-runner'. That will add the Flink dependency to your classpath when > you execute the pipeline. > > On Wed, May 24, 2017 at 2:35 PM, Claire Yuan <[email protected]> > wrote: > >> Hi all, >> When I tried specify the runner in command for the examples: >> * mvn exec:java -Dexec.mainClass=org.apache.be >> <http://org.apache.be>am.examples.WordCount >> -Dexec.args="--output=wordcount.txt --runner=FlinkRunner" * >> >> The building was failed and got error message as: >> *Failed to execute goal org.codehaus.mojo:exec-maven-plugin:1.5.0:java >> (default-cli) on project beam-examples-java: An exception occured while >> executing the Java class. null: InvocationTargetException: Unknown 'runner' >> specified 'FlinkRunner', supported pipeline runners [DirectRunner] -> [Help >> 1]* >> >> I am wondering if anyone got the same issue and how you solved it. >> > >
