You'll need to implement an custom sink for that.
Best, Zhanghao Chen ________________________________ From: Ilya Karpov <[email protected]> Sent: Monday, February 3, 2025 18:30 To: user <[email protected]> Subject: Dead Letter Queue for FlinkSQL Hi there, Because sink connectors can throw exceptions in real time (for example, due to constraint violation) it's a good practice to have DLQ to continue data processing. Is there any way in FlinkSQL to implement/configure DLQ? Thanks forward!
