Hi, How are concurrent snapshots taken for an operator? Let's say an operator receives barriers for a checkpoint from all of its inputs. It triggers the checkpoint. Now, the checkpoint starts getting saved asynchronously. Before the checkpoint is acknowledged, the operator receives all barriers for all inputs for the next checkpoint. What will happen in this case if no concurrent checkpoints are allowed (i.e. the default value is used)? What will happen if concurrent checkpoints are allowed?
Thanks, Narendra Joshi
