[jira] [Created] (BEAM-196) Pipeline options must be available Context in DoFn.startBundle

["Mark Shields (JIRA)" <ji...@apache.org>]

Mark Shields created BEAM-196:
---------------------------------

             Summary: Pipeline options must be available Context in DoFn.startBundle
                 Key: BEAM-196
                 URL: https://issues.apache.org/jira/browse/BEAM-196
             Project: Beam
          Issue Type: Bug
          Components: runner-flink
            Reporter: Mark Shields
            Assignee: Maximilian Michels


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.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)