Add Flink instructions to portability contrib page.#506
Closed
tweise wants to merge 2 commits intoapache:asf-sitefrom
Closed
Add Flink instructions to portability contrib page.#506tweise wants to merge 2 commits intoapache:asf-sitefrom
tweise wants to merge 2 commits intoapache:asf-sitefrom
Conversation
Author
|
CC: @angoenka |
angoenka
reviewed
Jul 20, 2018
| 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` | ||
|
|
||
| Note: A subset of the functionality is also supported in streaming mode; use `--streaming` in the command line to enable it. |
There was a problem hiding this comment.
Shall we also add the complete command for streaming usecase to make it easier for our users.
| 1. Run once to build the SDK harness container: `./gradlew -p 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` |
There was a problem hiding this comment.
We can also add instructions to schedule it on a local flink cluster.
./gradlew :beam-runners-flink_2.11-job-server:shadowJar and then run the jar with appropriate arguments including endpoint for FlinkJobserver
src/contribute/portability.md
Outdated
| ### Status | ||
|
|
||
| MVP in progress. See the | ||
| MVP complete (for Flink runner). See the |
There was a problem hiding this comment.
Should we wait for the ValidatesRunner test success before we call it complete?
tweise
force-pushed
the
portabilityInstructions
branch
from
4181d79 to
c6c738c
Compare
Author
|
test this please |
Author
|
@asfgit merge |
|
Error: PR failed in verification; check the Jenkins job for more information. |
Member
|
@asfgit merge |
swegner
pushed a commit
to swegner/beam
that referenced
this pull request
Sep 19, 2018
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
4 participants
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
Please add a meaningful description for your change here.
Once your pull request has been opened and assigned a number, please edit the
URL below, replacing
PULL_REQUEST_NUMBERwith the number of your pull request.http://apache-beam-website-pull-requests.storage.googleapis.com/PULL_REQUEST_NUMBER/index.html
Finally, it will help us expedite review of your Pull Request if you tag
someone (e.g. @username) to look at it.