[
https://issues.apache.org/jira/browse/BEAM-2400?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16421819#comment-16421819
]
Daniel Salerno de Arruda edited comment on BEAM-2400 at 4/1/18 11:15 PM:
-
Any official solution?
[~Tobi] I tried this path that you suggested, the template is created without
exceptions. However, when the template is run by Dataflow runner, the main
pipeline code works correctly but the code after run () is not executed. It
seems that waitUntilFinish does not work when it is run from a template.
was (Author: daniel salerno):
Any official solution?
> Null pointer exception when creating a template
> ---
>
> Key: BEAM-2400
> URL: https://issues.apache.org/jira/browse/BEAM-2400
> Project: Beam
> Issue Type: Bug
> Components: runner-dataflow
>Reporter: Melissa Pashniak
>Priority: Minor
>
> The template is successfully created, but is then followed by a null pointer
> exception.
> Command:
> mvn compile exec:java -Dexec.mainClass=com.example.WordCount
> -Dexec.args="--runner=DataflowRunner \
> --project=my-project \
> --stagingLocation=gs://my-bucket/staging \
> --output=gs://my-bucket/output/outputfile \
> --templateLocation=gs://my-bucket/templates/mytemplate"
> INFO: Template successfully created.
> [WARNING]
> java.lang.reflect.InvocationTargetException
> at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
> at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> at java.lang.reflect.Method.invoke(Method.java:606)
> at org.codehaus.mojo.exec.ExecJavaMojo$1.run(ExecJavaMojo.java:293)
> at java.lang.Thread.run(Thread.java:745)
> Caused by: java.lang.NullPointerException
> at
> org.apache.beam.runners.dataflow.DataflowPipelineJob.getJobWithRetries(DataflowPipelineJob.java:489)
> at
> org.apache.beam.runners.dataflow.DataflowPipelineJob.getStateWithRetries(DataflowPipelineJob.java:465)
> at
> org.apache.beam.runners.dataflow.DataflowPipelineJob.waitUntilFinish(DataflowPipelineJob.java:304)
> at
> org.apache.beam.runners.dataflow.DataflowPipelineJob.waitUntilFinish(DataflowPipelineJob.java:240)
> at
> org.apache.beam.runners.dataflow.DataflowPipelineJob.waitUntilFinish(DataflowPipelineJob.java:193)
> at
> org.apache.beam.runners.dataflow.DataflowPipelineJob.waitUntilFinish(DataflowPipelineJob.java:186)
> at com.example.WordCount.main(WordCount.java:184)
> ... 6 more
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
