You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by da...@apache.org on 2016/12/02 21:44:17 UTC
[1/3] incubator-beam-site git commit: Simplify Flink Runner
instructions for running on cluster
Repository: incubator-beam-site
Updated Branches:
refs/heads/asf-site 33a2bb45a -> b6423e5f4
Simplify Flink Runner instructions for running on cluster
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/f92e07c5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/f92e07c5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/diff/f92e07c5
Branch: refs/heads/asf-site
Commit: f92e07c53cfab50888e4cc8fb7aa46c85b3524b9
Parents: 33a2bb4
Author: Aljoscha Krettek <al...@gmail.com>
Authored: Thu Dec 1 21:51:54 2016 +0100
Committer: Davor Bonaci <da...@google.com>
Committed: Fri Dec 2 13:43:54 2016 -0800
----------------------------------------------------------------------
src/get-started/quickstart.md | 9 +++------
1 file changed, 3 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/f92e07c5/src/get-started/quickstart.md
----------------------------------------------------------------------
diff --git a/src/get-started/quickstart.md b/src/get-started/quickstart.md
index 73f3064..3bd4b98 100644
--- a/src/get-started/quickstart.md
+++ b/src/get-started/quickstart.md
@@ -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
```
[2/3] incubator-beam-site git commit: Regenerate website
Posted by da...@apache.org.
Regenerate website
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/18d5db7e
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/18d5db7e
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/diff/18d5db7e
Branch: refs/heads/asf-site
Commit: 18d5db7e2e344e4a1da3405a91e675b1f6cd13a2
Parents: f92e07c
Author: Davor Bonaci <da...@google.com>
Authored: Fri Dec 2 13:44:07 2016 -0800
Committer: Davor Bonaci <da...@google.com>
Committed: Fri Dec 2 13:44:07 2016 -0800
----------------------------------------------------------------------
content/get-started/quickstart/index.html | 9 +++------
1 file changed, 3 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/18d5db7e/content/get-started/quickstart/index.html
----------------------------------------------------------------------
diff --git a/content/get-started/quickstart/index.html b/content/get-started/quickstart/index.html
index 218863a..b1b33ab 100644
--- a/content/get-started/quickstart/index.html
+++ b/content/get-started/quickstart/index.html
@@ -232,12 +232,9 @@ MinimalWordCount.java WordCount.java
</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=<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
</code></pre>
[3/3] incubator-beam-site git commit: This closes #99
Posted by da...@apache.org.
This closes #99
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/b6423e5f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/b6423e5f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/diff/b6423e5f
Branch: refs/heads/asf-site
Commit: b6423e5f42c67df0e5b1d2d6c6c758755de01cfa
Parents: 33a2bb4 18d5db7
Author: Davor Bonaci <da...@google.com>
Authored: Fri Dec 2 13:44:07 2016 -0800
Committer: Davor Bonaci <da...@google.com>
Committed: Fri Dec 2 13:44:07 2016 -0800
----------------------------------------------------------------------
content/get-started/quickstart/index.html | 9 +++------
src/get-started/quickstart.md | 9 +++------
2 files changed, 6 insertions(+), 12 deletions(-)
----------------------------------------------------------------------