The example needs --inputFile, not --input, to designate the input file
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/f930380b Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/f930380b Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/f930380b Branch: refs/heads/master Commit: f930380ba03ad1f19d5bb1070823a5b403e6f93f Parents: 22331d1 Author: Roberto Congiu <rcon...@agentace.com> Authored: Mon Nov 23 12:11:37 2015 -0800 Committer: Tom White <t...@cloudera.com> Committed: Thu Mar 10 11:15:17 2016 +0000 ---------------------------------------------------------------------- runners/spark/README.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/f930380b/runners/spark/README.md ---------------------------------------------------------------------- diff --git a/runners/spark/README.md b/runners/spark/README.md index d3429fe..ccf8516 100644 --- a/runners/spark/README.md +++ b/runners/spark/README.md @@ -94,7 +94,7 @@ Then run the word count example using Spark submit with the `yarn-client` master --class com.google.cloud.dataflow.examples.WordCount \ --master yarn-client \ target/spark-dataflow-*-spark-app.jar \ - --input=kinglear.txt --output=out --runner=SparkPipelineRunner --sparkMaster=yarn-client + --inputFile=kinglear.txt --output=out --runner=SparkPipelineRunner --sparkMaster=yarn-client Check the output by running:
