[ https://issues.apache.org/jira/browse/BEAM-1948?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Etienne Chauchot updated BEAM-1948: ----------------------------------- Priority: Minor (was: Major) > 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 > Priority: Minor > > 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 == null {code} > 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)