Getting getSplitBacklogBytes() unable to read bytes error after draining Streaming Dataflow job

Hi marc thanks for your reply will try the suggested approach… I was using java connector and draining job as i want to only run it for some time though its a streaming job