You'll need to implement an custom sink for that.
Best, Zhanghao Chen ________________________________ From: Ilya Karpov <idkf...@gmail.com> Sent: Monday, February 3, 2025 18:30 To: user <user@flink.apache.org> 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!
