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)
