beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Etienne Chauchot (JIRA)" <j...@apache.org>
Subject [jira] [Created] (BEAM-1948) Null pointer exception in DirectRunner.DirectPipelineResult.getAggregatorValues()
Date Wed, 12 Apr 2017 13:37:41 GMT
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)

Mime
View raw message