[ https://issues.apache.org/jira/browse/BEAM-4199?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Anton Kedin closed BEAM-4199. ----------------------------- Resolution: Fixed Fix Version/s: Not applicable > [SQL] Add a DLQ support for Pubsub tables > ----------------------------------------- > > Key: BEAM-4199 > URL: https://issues.apache.org/jira/browse/BEAM-4199 > Project: Beam > Issue Type: Improvement > Components: dsl-sql > Reporter: Anton Kedin > Assignee: Anton Kedin > Priority: Major > Fix For: Not applicable > > Time Spent: 2.5h > Remaining Estimate: 0h > > Currently we crash the pipeline if there's any error processing the message > from the pubsub, including if it has incorrect JSON format, like missing > fields etc. > Correct solution would be for the user to specify a way to handle the errors, > and ideally point to a dead-letter-queue where Beam should send the messages > it could not process. -- This message was sent by Atlassian JIRA (v7.6.3#76005)