[BEAM-9031] Wrong Python example in Flink runner documentation

• Type: Bug
• Status: Resolved
• Priority: P4
• Resolution: Fixed
• Affects Version/s: Not applicable
• Fix Version/s: Not applicable
• Component/s: website
• Labels: documentation easyfix newbie
• Assignee: Berkay Öztürk
• Reporter: Berkay Öztürk
• Created: 26/Dec/19 12:15
• Updated: 16/May/20 14:22
• Resolved: 31/Dec/19 09:05

Description

Python example under the Executing a Beam pipeline on a Flink Cluster header will throw this error:

TypeError: Runner PipelineOptions() is not a PipelineRunner object or the name of a registered runner

Fix:

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:
    ...

Issue Links

• links to: GitHub Pull Request #10465