Greetings,
I would like to find out more about Flink's new reactive mode as well as the rescaling feature regarding fault tolerance. For the following question lets assume checkpointing is enabled using HDFS. So first question, if I have a job where the source(s) and sink(s) are configured to use Kafka with exactly-once processing enabled, how does reactive mode handle this? On reconfigurations using the Horizontal Pod Autoscaler, does it recover to the latest checkpoint? Second question, for re-scaling, does it automatically create a savepoint and then rescale or does it use the latest checkpoint to ensure results are consistent during reconfiguration. Thank you in advance! M.
