Hi Shivam, Thanks a lot for your response. Yes it is a batch pipeline. My task is to read a big query table, process the data and publish the Rows as a PubSub message.
Regards, Ashok On Mon, 6 Feb 2023 at 10:52 pm, Shivam Singhal <shivamsinghal5...@gmail.com> wrote: > Hey Ashok KS, > > Is this a batch pipeline? > > On Mon, 6 Feb 2023 at 09:27, Ashok KS <ashok7...@gmail.com> wrote: > >> Hi All, >> >> Just sending a reminder in case anyone could help. I haven't received any >> response to my issue. >> >> Regards, >> Ashok >> >> On Fri, Feb 3, 2023 at 12:23 AM Ashok KS <ashok7...@gmail.com> wrote: >> >>> Hi All, >>> >>> I'm new to using Apache Beam using Go. >>> >>> pubsubio.Write(scope, "project", "topic", ppMessages) >>> When I try to publish a message in a topic I get an error message >>> "Could not find the sink for pubsub, Check that the sink library >>> specifies alwayslink = 1 >>> >>> I found a StackOverFlow post for the same issue but it doesn't solve the >>> problem. >>> >>> Stackoverflow Link >>> <https://stackoverflow.com/questions/69651665/go-apache-beam-gcp-dataflow-could-not-find-the-sink-for-pubsub-check-that-th> >>> >>> Can someone please help? >>> >>> Regards, >>> Ashok >>> >>
