[
https://issues.apache.org/jira/browse/BEAM-14221?focusedWorklogId=751288&page=com.atlassian.jira.plugin.system.issuetabpanels:worklog-tabpanel#worklog-751288
]
ASF GitHub Bot logged work on BEAM-14221:
-----------------------------------------
Author: ASF GitHub Bot
Created on: 31/Mar/22 23:30
Start Date: 31/Mar/22 23:30
Worklog Time Spent: 10m
Work Description: VictorPlusC commented on a change in pull request
#17232:
URL: https://github.com/apache/beam/pull/17232#discussion_r840104482
##########
File path: sdks/python/apache_beam/runners/interactive/README.md
##########
@@ -263,6 +269,23 @@ You can choose to run Interactive Beam on Flink with the
following settings.
p =
beam.Pipeline(interactive_runner.InteractiveRunner(underlying_runner=flink_runner.FlinkRunner()))
```
+* Alternatively, if the runtime environment is configured with a Google
Cloud project, you may run Flink pipelines remotely on Dataproc. To do so, only
a project is required to be specified when running from an official release,
otherwise, it is necessary to specify an `environment_config` option to select
a specific release version. Furthermore, it is recommended to cache into a
Google Cloud bucket.
Review comment:
Sounds good! I've added your suggestion now. Thanks!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
Issue Time Tracking
-------------------
Worklog Id: (was: 751288)
Time Spent: 2h (was: 1h 50m)
> Update documentation with Flink on Dataproc features
> ----------------------------------------------------
>
> Key: BEAM-14221
> URL: https://issues.apache.org/jira/browse/BEAM-14221
> Project: Beam
> Issue Type: Improvement
> Components: runner-py-interactive
> Reporter: Victor Chen
> Assignee: Victor Chen
> Priority: P2
> Time Spent: 2h
> Remaining Estimate: 0h
>
> Updates relevant documentation with all merged changes implementing the Flink
> on Dataproc project.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
