Re: Handling non-transient exceptions

2022-04-19 Thread Guowei Ma
ht cause irreparable damage > to applications but it could be configured per exception. > > > > > > Regards, > > José Brandão > > > > *From: *Guowei Ma > *Date: *Friday, 15 April 2022 at 11:04 > *To: *Jose Brandao > *Cc: *user@flink.apache.org > *Subj

Re: Handling non-transient exceptions

2022-04-18 Thread Jose Brandao
exception. Regards, José Brandão From: Guowei Ma Date: Friday, 15 April 2022 at 11:04 To: Jose Brandao Cc: user@flink.apache.org Subject: Re: Handling non-transient exceptions EXTERNAL SENDER: This email originated from outside our email system. If you find this email suspicious please use

Re: Handling non-transient exceptions

2022-04-15 Thread Guowei Ma
Hi, Jose I assume you are using the DataStream API. In general for any udf's exception in the DataStream job, only the developer of the DataStream job knows whether the exception can be tolerated. Because in some cases, tolerating exceptions can cause errors in the final result. So you still have

Handling non-transient exceptions

2022-04-14 Thread Jose Brandao
Hello, Searching some expertise on exception handling with checkpointing and streaming. Let’s say some bad data flows into your Flink application and causes an exception you are not expecting. That exception will bubble up, ending up in killing the respective task and the app will not be able