Hi all, I am trying to figure out the right approach to handling failed records when persisting to a database through the JdbcIO sink. We have created a DoFn to do this task through a PreparedStatement and catch any exceptions then send it through side output for further processing if required. Is there any built-in way of handling this?
Thank you.
