Simplify Flink Runner instructions for running on cluster#99
Simplify Flink Runner instructions for running on cluster#99aljoscha wants to merge 1 commit intoapache:asf-sitefrom aljoscha:simplify-flink-quickstart
Conversation
|
Refer to this link for build results (access rights to CI server needed): |
|
Refer to this link for build results (access rights to CI server needed): Jenkins built the site at commit id 997e045 with Jekyll and staged it here. Happy reviewing. Note that any previous site has been deleted. This staged site will be automatically deleted after its TTL expires. Push any commit to the pull request branch or re-trigger the build to get it staged again. |
| --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 \ |
There was a problem hiding this comment.
/path/to/quickstart/pom.xml --> pom.xml?
(for consistency)
(the reference target/ is already dependent on the current directory)
There was a problem hiding this comment.
I made it like this because the jar path can be relative to the current directory while inputFile and output file usually are paths to somewhere in a distributed filesystem. What do you think?
There was a problem hiding this comment.
Agreed.
I'm hoping users can copy and paste the command as much as possible. It would be great if they wouldn't need to modify the parameter. So, if this works end-to-end, I'd just use pom.xml. Otherwise, I think your approach is better.
However, this is too-low level point anyways. This PR is an improvement, so I'll merge it. Feel free to push another one if you agree with the change. Otherwise, ignore.
3 participants
R: @davorbonaci I think this should be simple/straighforward enough now 😃