Stateful Functions pauses routing during checkpoint.

2022-05-05 Thread Ammon Diether
Flink Stateful Functions 3.2.0 (Flink 1.14.3) All java embedded code. Parallelism 32 Standard Stateful Functions Tasks: router -> functions -> feedback The Router reads from kinesis and routes to stateful functions. For some reason, one and only one of the router subtasks will have have a start

Re: Stateful Functions pauses routing during checkpoint.

2022-05-05 Thread Ammon Diether
I should probably clarify that this is intermittent and it is a different subtask ID each time it does happen. On Thu, May 5, 2022 at 4:25 PM Ammon Diether wrote: > Flink Stateful Functions 3.2.0 (Flink 1.14.3) > All java embedded code. > Parallelism 32 > Standard Stateful Functions Tasks: rou