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.beam.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. >
