[jira] [Commented] (BEAM-1977) PubsubIO fails with NPE on ACK when running locally

["Thomas Groh (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/BEAM-1977?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15969343#comment-15969343 ] 

Thomas Groh commented on BEAM-1977:
-----------------------------------

This is fixed in HEAD, and in the currently nightly build.

To update to the current nightly build you will have to add the following repositories to your project's pom.xml, and update your version either to a specific nightly build or to 0.7.0-SNAPSHOT
{{
    <repositories>
      <repository>
        <id>apache.snapshots</id>
        <name>Apache Development Snapshot Repository</name>

 <url>https://repository.apache.org/content/repositories/snapshots/</url>
        <releases>
          <enabled>false</enabled>
        </releases>
        <snapshots>
          <enabled>true</enabled>
        </snapshots>
      </repository>

    </repositories>
}}

(Taken from http://stackoverflow.com/questions/42984238/apache-beam-pubsubreader-fails-with-npe/43005418#43005418)

> PubsubIO fails with NPE on ACK when running locally
> ---------------------------------------------------
>
>                 Key: BEAM-1977
>                 URL: https://issues.apache.org/jira/browse/BEAM-1977
>             Project: Beam
>          Issue Type: Bug
>          Components: sdk-java-core
>    Affects Versions: 0.6.0
>            Reporter: Keith Berkoben
>            Assignee: Davor Bonaci
>
> When running a PubsubIO-fed pipeline on a local machine, the pipeline runs for 10sec and then fails with a NPE (I'd guess when trying to ACK messages?). 
> Logs confirm I am successfully reading messages and writing them out to pubsubIO, at least for a while.
> Stack trace: 
> Exception in thread "main" java.lang.NullPointerException
>         at org.apache.beam.sdk.io.PubsubUnboundedSource$PubsubReader.ackBatch(PubsubUnboundedSource.java:640)
>         at org.apache.beam.sdk.io.PubsubUnboundedSource$PubsubCheckpoint.finalizeCheckpoint(PubsubUnboundedSource.java:313)
>         at org.apache.beam.runners.direct.UnboundedReadEvaluatorFactory$UnboundedReadEvaluator.getReader(UnboundedReadEvaluatorFactory.java:174)
>         at org.apache.beam.runners.direct.UnboundedReadEvaluatorFactory$UnboundedReadEvaluator.processElement(UnboundedReadEvaluatorFactory.java:127)
>         at org.apache.beam.runners.direct.TransformExecutor.processElements(TransformExecutor.java:139)
>         at org.apache.beam.runners.direct.TransformExecutor.run(TransformExecutor.java:107)
>         at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
>         at java.util.concurrent.FutureTask.run(FutureTask.java:266)
>         at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
>         at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
>         at java.lang.Thread.run(Thread.java:745)



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