I created a issue to trace this feature: https://issues.apache.org/jira/browse/FLINK-15440
Best, Kurt On Tue, Dec 31, 2019 at 8:00 AM Fanbin Bu <fanbin...@coinbase.com> wrote: > Kurt, > > Is there any update on this or roadmap that supports savepoints with Flink > SQL? > > On Sun, Nov 3, 2019 at 11:25 PM Kurt Young <k...@apache.org> wrote: > >> It's not possible for SQL and Table API jobs playing with savepoints yet, >> but I >> think this is a popular requirement and we should definitely discuss the >> solutions >> in the following versions. >> >> Best, >> Kurt >> >> On Sat, Nov 2, 2019 at 7:24 AM Fanbin Bu <fanbin...@coinbase.com> wrote: >> >>> 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 >>>> >>>
