Hello, Thanks for quick reply.
I am using parquet encoder/decoder and during decoding if any corrupt record comes then need to raise alarm and maintain metrices visible over Flink Metrices GUI. So any custom metrices can be created in Flink? Please give some reference of any such documentation. Rgds, Kamal From: Martijn Visser <martijnvis...@apache.org> Sent: 07 June 2023 12:31 PM To: Kamal Mittal <kamal.mit...@ericsson.com> Cc: user@flink.apache.org Subject: Re: Raise alarm for corrupt records Hi Kamal, No, but it should be straightforward to create metrics or events for these types of situations and integrate them with your own alerting solution. Best regards, Martijn On Wed, Jun 7, 2023 at 8:25 AM Kamal Mittal via user <user@flink.apache.org<mailto:user@flink.apache.org>> wrote: Hello Community, Is there any way Flink provides out of box to raise alarm for corrupt records (e.g. due to decoding failure) in between of running data pipeline and send this alarm to outside of task manager process? Rgds, Kamal
