[BEAM-196] Pipeline options must be available Context in DoFn.startBundle

• Type: Bug
• Status: Resolved
• Priority: P2
• Resolution: Fixed
• Fix Version/s: 0.1.0-incubating
• Component/s: runner-flink
• Assignee: Maximilian Michels
• Reporter: Mark Shields
• Created: 14/Apr/16 22:56
• Updated: 24/Jul/20 20:56
• Resolved: 08/Jun/16 16:11

Description

Our (not yet merged) Java Pubsub implementation has code like this in a DoFn:

@Override
public void startBundle(Context c) throws Exception

{ Preconditions.checkState(pubsubClient == null); pubsubClient = PubsubClient.newClient(transportType, timestampLabel, idLabel, c.getPipelineOptions().as(PubsubOptions.class)); super.startBundle(c); }

This fails with NPE since the pipeline options are not conveyed via the context.

Issue Links

• links to: GitHub Pull Request #432