Kurt, What do you recommend for Flink SQL to use savepoints?
On Thu, Oct 31, 2019 at 12:03 AM Yun Tang <myas...@live.com> wrote: > Hi Fanbin > > > > If you do not change the parallelism or add and remove operators, you > could still use savepoint to resume your jobs with Flink SQL. > > > > However, as far as I know, Flink SQL might not configure the uid currently > and I’m pretty sure blink branch contains this part of setting uid to > stream node. [1] > > > > Already CC Kurt as he could provide more detail information of this. > > > > [1] > https://github.com/apache/flink/blob/blink/flink-libraries/flink-table/src/main/java/org/apache/flink/table/util/resource/StreamNodeUtil.java#L44 > > > > Best > > Yun Tang > > > > > > *From: *Fanbin Bu <fanbin...@coinbase.com> > *Date: *Thursday, October 31, 2019 at 1:17 PM > *To: *user <user@flink.apache.org> > *Subject: *Flink SQL + savepoint > > > > Hi, > > > > it is highly recommended that we assign the uid to the operator for the > sake of savepoint. How do we do this for Flink SQL? According to > https://stackoverflow.com/questions/55464955/how-to-add-uid-to-operator-in-flink-table-api, > it is not possible. > > > > Does that mean, I can't use savepoint to restart my program if I use Flink > SQL? > > > > Thanks, > > > > Fanbin >
