Hi,
you have to provide the profile: -Pflink-runner.
Regards
JB
On 05/24/2017 11:35 PM, Claire Yuan 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.
--
Jean-Baptiste Onofré
[email protected]
http://blog.nanthrax.net
Talend - http://www.talend.com
