[jira] [Updated] (BEAM-12080) Writing a bounded source to PubsubLiteIO using DirectRunner does not exit

["Beam JIRA Bot (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/BEAM-12080?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Beam JIRA Bot updated BEAM-12080:
---------------------------------
    Labels: PubsubLiteIO java stale-P2  (was: PubsubLiteIO java)

> Writing a bounded source to PubsubLiteIO using DirectRunner does not exit
> -------------------------------------------------------------------------
>
>                 Key: BEAM-12080
>                 URL: https://issues.apache.org/jira/browse/BEAM-12080
>             Project: Beam
>          Issue Type: Bug
>          Components: extensions-java-gcp, runner-direct
>    Affects Versions: 2.28.0
>            Reporter: Tianzi Cai
>            Priority: P2
>              Labels: PubsubLiteIO, java, stale-P2
>
> Writing a bounded source (with a single message) to Pub/Sub Lite using `PubsubLiteIO` via `DirectRunner` succeeds, but the pipeline does not exit after the work is completed.
> When using `DataflowRunner`, the job stops and shuts down cleanly.
> {code:java}
> import com.google.cloud.pubsublite.Message;
> import org.apache.beam.sdk.io.gcp.pubsublite.PubsubLiteIO;
> // ...
> Message message =
>     Message.builder()
>         .setData(ByteString.copyFromUtf8("Hello world from Dataflow!"))
>         .setEventTime(fromMillis(System.currentTimeMillis()))
>         .build();
> pipeline
>     .apply(Create.of(message.toProto()))
>     .apply("Write to Pub/Sub Lite", PubsubLiteIO.write(publisherOptions));
> {code}



--
This message was sent by Atlassian Jira
(v8.3.4#803005)