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
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