Flink SQL + savepoint

2019-10-30 Thread Fanbin Bu
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 res

Re: Flink SQL + savepoint

2019-10-31 Thread Yun Tang
at 1:17 PM To: user 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

Re: Flink SQL + savepoint

2019-11-01 Thread Fanbin Bu
> 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 > *Date: *Thursday, October 31, 2019 at 1:17 PM > *To:

Re: Flink SQL + savepoint

2019-11-03 Thread Kurt Young
ore 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 >&g

Re: Flink SQL + savepoint

2019-12-30 Thread Fanbin Bu
l 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 >>&g

Re: Flink SQL + savepoint

2019-12-30 Thread Kurt Young
ld 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 >>>> &