Hi there, I just had the idea of a "ReplayableSourceStateBackend". I opened up a JIRA issue where I described the idea about it [1].
I would love to hear your feedback: Do you think it is possible to implement (I am not sure if a pipeline can be fully reconstructed from the source elements when it e.g. comes to closing session windows or such)? Would it be useful for your usecases as well? Best regards Theo [1] https://issues.apache.org/jira/browse/FLINK-19382
