How to restore state from savepoint with flink SQL

Posted by Yan Zhou [FDS Science] ­ on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/How-to-restore-state-from-savepoint-with-flink-SQL-tp20273.html

Hi,

My application use flink SQL and it's running in production. How can i update my application with topology changes yet doesn't lose the state data?

Is there a way to assign UID to the operators that are translated from SQL? If not, is it intended and whats the rationality behind it? 

According to the flink document[1], UID has to be manually assigned to each operator.  Otherwise changing the topology will very likely change the UID, which in return messes up the state restoring from savepoint. 

Please advise.

[1] https://ci.apache.org/projects/flink/flink-docs-master/ops/state/savepoints.html#assigning-operator-ids

Apache Flink 1.6-SNAPSHOT Documentation: Savepoints ci.apache.org Assigning Operator IDs. It is highly recommended that you adjust your programs as described in this section in order to be able to upgrade your programs in the future. The main required change is to manually specify operator IDs via the uid(String) method.