Add a filtering step to skip these types of errors in the future, extract erroneous rows from logs.

Add a try... catch block to your DoFn that transforms the data, extract erroneous rows from logs.

Add a try... catch block to your DoFn that transforms the data, use a sideOutput to create a PCollection that can be stored to PubSub later.