From 6f9c7b16f5bf81089288dedde9d6ea0dea9f7d0c Mon Sep 17 00:00:00 2001 From: rajkgupt Date: Mon, 22 Apr 2024 17:20:19 +0530 Subject: [PATCH 1/2] add DataflowRunner in wordCount run command with Gradle add DataflowRunner in wordCount run command with Gradle --- website/www/site/content/en/get-started/quickstart-java.md | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/website/www/site/content/en/get-started/quickstart-java.md b/website/www/site/content/en/get-started/quickstart-java.md index 6d12cc5e92896..26d758f994dbd 100644 --- a/website/www/site/content/en/get-started/quickstart-java.md +++ b/website/www/site/content/en/get-started/quickstart-java.md @@ -297,7 +297,7 @@ TODO: document Spark on Gradle: https://github.com/apache/beam/issues/21502 {{< runner dataflow >}} gradle clean execute -DmainClass=org.apache.beam.examples.WordCount \ --args="--project= --inputFile=gs://apache-beam-samples/shakespeare/* \ - --output=gs:///counts" -Pdataflow-runner + --output=gs:///counts --runner=DataflowRunner" -Pdataflow-runner {{< /runner >}} {{< runner samza>}} TODO: document Samza on Gradle: https://github.com/apache/beam/issues/21500 From 4570a6324dfed7d044ad197f69928104bbaa76ed Mon Sep 17 00:00:00 2001 From: rajkgupt Date: Mon, 22 Apr 2024 17:26:44 +0530 Subject: [PATCH 2/2] Update dataflow.md to update mvn package and run commands Update dataflow.md to update mvn package and run commands --- .../www/site/content/en/documentation/runners/dataflow.md | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/website/www/site/content/en/documentation/runners/dataflow.md b/website/www/site/content/en/documentation/runners/dataflow.md index 7b5d3e60f5678..49d341a860061 100644 --- a/website/www/site/content/en/documentation/runners/dataflow.md +++ b/website/www/site/content/en/documentation/runners/dataflow.md @@ -101,7 +101,7 @@ Then, add the mainClass name in the Maven JAR plugin. {{< /highlight >}} {{< paragraph class="language-java" >}} -After running mvn package, run ls target and you should see (assuming your artifactId is `beam-examples` and the version is 1.0.0) the following output. +After running mvn package -Pdataflow-runner, run ls target and you should see (assuming your artifactId is `beam-examples` and the version is 1.0.0) the following output. {{< /paragraph >}} {{< highlight java >}} @@ -117,7 +117,8 @@ java -jar target/beam-examples-bundled-1.0.0.jar \ --runner=DataflowRunner \ --project= \ --region= \ - --tempLocation=gs:///temp/ + --tempLocation=gs:///temp/ \ + --output=gs:///output {{< /highlight >}} ## Pipeline options for the Cloud Dataflow Runner {#pipeline-options}