Implement Reusable Error Handling for Flink UDFs

DataSQRL / sqrl

Flexible development framework for building streaming data applications in SQL with Kafka, Flink, Postgres, GraphQL, and more.

https://www.datasqrl.com/

97 stars 14 forks source link

Implement Reusable Error Handling for Flink UDFs #862

Open nandorsoma opened 1 month ago

nandorsoma commented 1 month ago

To improve the stability and reliability of our Flink UDFs, we need to implement a robust and reusable error-handling mechanism. This should ensure that invalid input arguments or exceptions from underlying libraries are handled gracefully without disrupting the pipeline.

henneberger commented 1 month ago

Could you elaborate on what you had in mind?