Details
-
Bug
-
Status: Resolved
-
P3
-
Resolution: Fixed
-
2.28.0
Description
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.
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));