[jira] [Created] (BEAM-1948) Null pointer exception in DirectRunner.DirectPipelineResult.getAggregatorValues()

["Etienne Chauchot (JIRA)" <ji...@apache.org>]

Etienne Chauchot created BEAM-1948:
--------------------------------------

             Summary: Null pointer exception in DirectRunner.DirectPipelineResult.getAggregatorValues()
                 Key: BEAM-1948
                 URL: https://issues.apache.org/jira/browse/BEAM-1948
             Project: Beam
          Issue Type: Bug
          Components: runner-direct
            Reporter: Etienne Chauchot
            Assignee: Thomas Groh


Running query3 of nexmark (https://github.com/iemejia/beam/blob/BEAM-160-nexmark/integration/java/nexmark/src/main/java/org/apache/beam/integration/nexmark/queries/Query3Model.java) in streaming mode (UnboundedSource) on Direct runner generates a null pointer exception  in {code} DirectRunner.DirectPipelineResult.getAggregatorValues() {code}

In
{code} if (steps.contains(transform.getTransform())) {code}
{code} steps {code} is null

to reproduce it :
run {code} NexmarkDirectDriver.main() {code}
with options
{code}
--query=3 --streaming=true --numEventGenerators=4 --manageResources=false --monitorJobs=true --enforceEncodability=false --enforceImmutability=false
{code}
see the repo in link above



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)