Hi Zhu Zhu and Abhinav,
I am able to verify the recovery from checkpoint based on your suggestions,
thanks a lot for the help!
Eleanore
On Wed, Mar 4, 2020 at 5:40 PM Bajaj, Abhinav
wrote:
> I implemented a custom function that throws up a runtime exception.
>
>
>
> You can extend from simpler
I implemented a custom function that throws up a runtime exception.
You can extend from simpler MapFunction or more complicated
RichParallelSourceFunction depending on your use case.
You can add logic to throw a runtime exception on a certain condition in the
map or run method. .
Y
Hi Eleanore,
You can change your application tasks to throw exceptions in a certain
frequency.
Alternatively, if the application has external dependencies (e.g. source),
you can trigger failures manually by manipulating the status of the
external service (e.g. shutdown the source service, or break
