(beam) branch master updated: fix for #30078 (#30079)

[yhu]

This is an automated email from the ASF dual-hosted git repository.

yhu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 582d5c03569 fix for #30078 (#30079)
582d5c03569 is described below

commit 582d5c03569186fbff5b48fc890cd6ed7c1fb283
Author: Neeraj Bansal <51872638+nrj...@users.noreply.github.com>
AuthorDate: Wed Jan 24 20:52:08 2024 +0530

    fix for #30078 (#30079)
    
    Co-authored-by: neeraj <neeraj.ban...@aeris.net>
---
 .../src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java       | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java
 
b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java
index e281e559a54..1080999271d 100644
--- 
a/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java
+++ 
b/sdks/java/io/google-cloud-platform/src/main/java/org/apache/beam/sdk/io/gcp/pubsub/PubsubIO.java
@@ -566,6 +566,8 @@ public class PubsubIO {
   public static Read<PubsubMessage> 
readMessagesWithAttributesAndMessageIdAndOrderingKey() {
     return Read.newBuilder()
         
.setCoder(PubsubMessageWithAttributesAndMessageIdAndOrderingKeyCoder.of())
+        .setNeedsAttributes(true)
+        .setNeedsMessageId(true)
         .setNeedsOrderingKey(true)
         .build();
   }