Hi,
Here is our case: a job, reading data from Kafka, doing some process and writing to HDFS, has
been running quite a while and has completed checkpoints. Now we'd like to add a new phase
in process and want to recover from a checkpoint taken before. The new phase may or may not
be stateful. Is it possible we do the recovery in respective case?