Thanks for the answer, the changes in the FLIP are quite interesting, are they coming in 1.2?
What I mean by "manually reading the savepoint" is that rather than providing the savepoint path via "the --fromSavepoint hdfs://some-path/to/savepoint" option I'd like to provide it in the code that initialises the StreamExecutionEnvironment. This way I can use my versioning strategy to load a savepoint that is compatible with the current version of the application (or none if this is a new version of the state, effectively rebuilding everything from Kafka). On the other side, i.e. writing the savepoint somewhere, at the moment I would be happy with triggering savepoints via CLI if it was possible to configure the path where they are stored via the initialisation code where we build the StreamExecutionEnvironment rather than via flink-conf.yml; since I don't see mention of this in the FLIP, is this something you would be happy to add as well? -- View this message in context: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/Controlling-savepoints-from-inside-an-application-tp9273p9276.html Sent from the Apache Flink User Mailing List archive. mailing list archive at Nabble.com.
