You are viewing a plain text version of this content. The canonical link for it is here.
Posted to github@beam.apache.org by GitBox <gi...@apache.org> on 2022/03/31 22:53:38 UTC

[GitHub] [beam] KevinGG commented on a change in pull request #17232: [BEAM-14221] Update documentation with Flink on Dataproc features

KevinGG commented on a change in pull request #17232:
URL: https://github.com/apache/beam/pull/17232#discussion_r840087007



##########
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:
       Maybe reword it to:
   
   ..., you can run Interactive Beam with Flink on Cloud Dataproc. To do so, configure the pipeline with a Google Cloud project. If using dev versioned Beam built from source code, it is necessary to ... option to configure a containerized Beam SDK (you can choose a released container or build one yourself).
   
   




-- 
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: github-unsubscribe@beam.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org