Skip to content

Commit

Permalink
This closes #99
Browse files Browse the repository at this point in the history
  • Loading branch information
davorbonaci committed Dec 2, 2016
2 parents 33a2bb4 + 18d5db7 commit b6423e5
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 12 deletions.
9 changes: 3 additions & 6 deletions content/get-started/quickstart/index.html
Original file line number Diff line number Diff line change
Expand Up @@ -232,12 +232,9 @@ <h2 id="run-wordcount">Run WordCount</h2>
</code></pre>
</div>

<div class="runner-flink-cluster highlighter-rouge"><pre class="highlight"><code>$ mvn package -Pflink-runner
$ cp target/word-count-beam-bundled-0.1.jar /path/to/flink/lib/
$ bin/flink run -c org.apache.beam.examples.WordCount lib/word-count-beam-0.1.jar \
--inputFile=/path/to/quickstart/pom.xml \
--output=/tmp/counts \
--runner=org.apache.beam.runners.flink.FlinkRunner
<div class="runner-flink-cluster highlighter-rouge"><pre class="highlight"><code>$ mvn package exec:java -Dexec.mainClass=org.apache.beam.examples.WordCount \
-Dexec.args="--runner=FlinkRunner --flinkMaster=&lt;flink master&gt; --filesToStage=target/word-count-beam-bundled-0.1.jar \
--inputFile=/path/to/quickstart/pom.xml --output=/tmp/counts" -Pflink-runner

You can monitor the running job by visiting the Flink dashboard at http://&lt;flink master&gt;:8081
</code></pre>
Expand Down
9 changes: 3 additions & 6 deletions src/get-started/quickstart.md
Original file line number Diff line number Diff line change
Expand Up @@ -88,12 +88,9 @@ $ mvn compile exec:java -Dexec.mainClass=org.apache.beam.examples.WordCount \

{:.runner-flink-cluster}
```
$ mvn package -Pflink-runner
$ cp target/word-count-beam-bundled-0.1.jar /path/to/flink/lib/
$ bin/flink run -c org.apache.beam.examples.WordCount lib/word-count-beam-0.1.jar \
--inputFile=/path/to/quickstart/pom.xml \
--output=/tmp/counts \
--runner=org.apache.beam.runners.flink.FlinkRunner
$ mvn package exec:java -Dexec.mainClass=org.apache.beam.examples.WordCount \
-Dexec.args="--runner=FlinkRunner --flinkMaster=<flink master> --filesToStage=target/word-count-beam-bundled-0.1.jar \
--inputFile=/path/to/quickstart/pom.xml --output=/tmp/counts" -Pflink-runner
You can monitor the running job by visiting the Flink dashboard at http://<flink master>:8081
```
Expand Down

0 comments on commit b6423e5

Please sign in to comment.