SO, I am using Beam pipeline in java whose job is to consume messages from solace queue and after consuming messages we are converting it to PCollection then we are writing this file to the GCS Bucket with .json extension.
So the problem is our code was working fine earlier with 3 different queues, but from past 4 days with 2 of the queue it was only consumuing messages but was not writing it to GCS bucket.
On the console we are getting messages like messageRecevied: lets say 10, messagesCheckpointReady:10,messageCheckpointComplete:0 … etc
then after some time
messageRecevied: 0 messagesCheckpointReady:0,messageCheckpointComplete:0 … etc
that means we have consumed messages from the queue but it is suppose to write it into GCS bucket which was working fine earlier but now it is not writing.
And we are running our code using direct runner on cloud shell