Re: [Statefun] Questions on recovery

2021-11-18 Thread Hady Januar Willi
> [4] > https://github.com/apache/flink-statefun/blob/master/statefun-e2e-tests/statefun-smoke-e2e-js/src/test/resources/remote-module/module.yaml#L20 > > Good luck, > Igal. > > On Wed, Nov 3, 2021 at 10:59 AM Hady Januar Willi > wrote: > >> Hi everyone, >>

[Statefun] Questions on recovery

2021-11-03 Thread Hady Januar Willi
Hi everyone, When testing Flink statefun, the job eventually throws the following exception after failing to reach the endpoint or if the endpoint fails after the exponentially increasing delay. java.util.concurrent.RejectedExecutionException: org.apache.flink.streaming.runtime.tasks.mailbox.Task