Berkay Öztürk created BEAM-9031:
-----------------------------------
Summary: Wrong Python example in Flink runner documentation
Key: BEAM-9031
URL: https://issues.apache.org/jira/browse/BEAM-9031
Project: Beam
Issue Type: Bug
Components: website
Affects Versions: Not applicable
Reporter: Berkay Öztürk
Fix For: Not applicable
Python example under the [Executing a Beam pipeline on a Flink
Cluster|https://beam.apache.org/documentation/runners/flink/#executing-a-beam-pipeline-on-a-flink-cluster]
header will throw this error:
{code}
TypeError: Runner PipelineOptions() is not a PipelineRunner object or the name
of a registered runner
{code}
Fix:
{code:python}
import apache_beam as beam
from apache_beam.options.pipeline_options import PipelineOptions
options = PipelineOptions([
"--runner=FlinkRunner",
"--flink_version=1.8",
"--flink_master=localhost:8081",
"--environment_type=LOOPBACK"
])
with beam.Pipeline(options=options) as p:
...
{code}
GitHub pull request on it's way.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
