Hi all, As far as I know, a stateful operator will checkpoint its current state to a persistent storage when it receives all the barrier from all of its upstream operators. My question is that does the operator doing the checkpoint need to pause processing the input tuples for the next batch until the checkpoint is done? If yes, will it introduce significant processing latency when the state is large. If no, does this need the operator state to be immutable?
Thanks, Li