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.

Reply via email to