We currently have some logic to load data from S3 into memory in our Flink/Kinesis Analytics app. This happens before the RichFunction.open() function.
We have two questions here and I can't find too much information in the apache.org website: 1. (More of a clarification) When Flink does checkpointing/savepointing only the state and the stream positions are saved right? The memory content won't be saved and restored. 2. When Flink restores from checkpoint/savepoint, does it still go through the application initialization phase? Basically will the code before the RichFunction' *open()* be run? If not, would the operators.open() functions run, when Flink restore from checkpoint/savepoint? Thanks, Jason
