Re: How to restore state from savepoint with flink SQL

2018-05-24 Thread Fabian Hueske
epends on its > location in the graph and its input/output. > > > Best > > Yan > -- > *From:* Fabian Hueske <fhue...@gmail.com> > *Sent:* Wednesday, May 23, 2018 3:18:08 AM > *To:* Yan Zhou [FDS Science] > *Cc:* user@flink.apache.org >

Re: How to restore state from savepoint with flink SQL

2018-05-23 Thread Fabian Hueske
Hi, At the moment, you can only restore a query from a savepoint if the query is not modified and the same Flink version is used. Since SQL queries are automatically translated into data flows, it is not transparent to the user, which operators will be created. We would need to expose an

How to restore state from savepoint with flink SQL

2018-05-22 Thread Yan Zhou [FDS Science]
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?