You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by me...@apache.org on 2018/09/06 05:41:45 UTC
[beam-site] branch mergebot updated (aa437b2 -> c54d1bb)
This is an automated email from the ASF dual-hosted git repository.
mergebot-role pushed a change to branch mergebot
in repository https://gitbox.apache.org/repos/asf/beam-site.git.
from aa437b2 This closes #543
add 3adb0c6 Prepare repository for deployment.
new 510b769 Fix portable Flink runner instructions.
new c54d1bb This closes #548
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
content/contribute/design-documents/index.html | 2 +-
src/contribute/portability.md | 8 ++++----
2 files changed, 5 insertions(+), 5 deletions(-)
[beam-site] 02/02: This closes #548
Posted by me...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
mergebot-role pushed a commit to branch mergebot
in repository https://gitbox.apache.org/repos/asf/beam-site.git
commit c54d1bb64e53f155ac8aa5b9d3d8d67042a81db0
Merge: 3adb0c6 510b769
Author: Mergebot <me...@apache.org>
AuthorDate: Thu Sep 6 05:41:07 2018 +0000
This closes #548
src/contribute/portability.md | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
[beam-site] 01/02: Fix portable Flink runner instructions.
Posted by me...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
mergebot-role pushed a commit to branch mergebot
in repository https://gitbox.apache.org/repos/asf/beam-site.git
commit 510b7690525db609b3ff2aab4794286defc63507
Author: Thomas Weise <th...@apache.org>
AuthorDate: Wed Sep 5 22:58:27 2018 +0200
Fix portable Flink runner instructions.
---
src/contribute/portability.md | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
diff --git a/src/contribute/portability.md b/src/contribute/portability.md
index c3abaad..4a4d9bb 100644
--- a/src/contribute/portability.md
+++ b/src/contribute/portability.md
@@ -183,10 +183,11 @@ for details.
The Flink runner is currently the only runner to support portable pipeline execution.
To run a basic Python wordcount (in batch mode) with embedded Flink:
-1. Run once to build the SDK harness container: `./gradlew -p sdks/python/container
-docker`
+1. Run once to build the SDK harness container: `./gradlew :beam-sdks-python-container:docker`
2. Start the Flink portable JobService endpoint: `./gradlew :beam-runners-flink_2.11-job-server:runShadow`
-3. Submit the wordcount pipeline to above endpoint: `./gradlew :beam-sdks-python:portableWordCount`
+3. Submit the wordcount pipeline to above endpoint: `./gradlew :beam-sdks-python:portableWordCount -PjobEndpoint=localhost:8099`
+
+To run the pipeline in streaming mode: `./gradlew :beam-sdks-python:portableWordCount -PjobEndpoint=localhost:8099 -Pstreaming`
To run on a separate [Flink cluster](https://ci.apache.org/projects/flink/flink-docs-release-1.5/quickstart/setup_quickstart.html):
@@ -196,4 +197,3 @@ To run on a separate [Flink cluster](https://ci.apache.org/projects/flink/flink-
4. Start JobService with Flink web service endpoint: `./gradlew :beam-runners-flink_2.11-job-server:runShadow -PflinkMasterUrl=localhost:8081`
5. Submit the pipeline.
-Note: A subset of the functionality is also supported in streaming mode; use `--streaming` in the command line to enable it.