Flink Failure Recovery: What if a stateless operator failed

167 Views Asked by At

We know, Flink creates checkpoints for every stateful operator periodically, and when crashes happen, it can use the checkpoints to recovery the system. But I can't find any paper or document about the stateless operator in these processes --"the creation of checkpoints" and "the recovery of fault".Thanks for your help.

1

There are 1 best solutions below

0
On

Stateless operators have no state, so there's nothing to checkpoint or restore, so that's why they aren't discussed in the context of checkpoint creation or recovery.