?????? ????FlinkSQL????operatoer??????savepoint??????????????

[kcz]

sql???????? 
operatorID??????????????????????????????????????????????????????????ID????????




------------------ ???????? ------------------
??????:&nbsp;"??????"<fskm...@gmail.com&gt;;
????????:&nbsp;2020??6??10??(??????) ????11:00
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

????:&nbsp;Re: ????FlinkSQL????operatoer??????savepoint??????????????



????????????????????????????org.apache.flink.runtime.checkpoint#loadAndValidateCheckpoint????????operator
ID??????????????????????????????????operator 
id??savepoint????id???????????????????????????????? ??operator
id??????????????????1.??????????2. ?????????? ????????????????????????????id,
????flink????????????????????id,????operator??id??????????????????????????????????????????????????????????????????operator
id?????????????????????????? ??????????????Assiging Operator IDs??????????????
?????? 
sql????????????operator??????????????????????sql????????????????operator??

?????? <fskm...@gmail.com&gt; ??2020??6??9?????? ????9:26??????

&gt;
&gt; 
????????org.apache.flink.runtime.checkpoint#loadAndValidateCheckpoint????????????????????????
&gt; ???????????????????????????????????????????????????? 
--allowNonRestoredState??????????????????????????
&gt; 
https://ci.apache.org/projects/flink/flink-docs-stable/ops/state/savepoints.html
&gt;
&gt; ????????????????????????
&gt;
&gt; ?????S <astion_...@163.com&gt; ??2020??6??8?????? ????11:53??????
&gt;
&gt;&gt; ????sql????????
&gt;&gt; CREATE TABLE A_source??...??
&gt;&gt; CREATE TABLE B_sink ??...??
&gt;&gt; INSERT INTO B_sink
&gt;&gt; SELECT
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 1
&gt;&gt; FROM
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp; A_source
&gt;&gt; ;
&gt;&gt; ??????????FlinkSQL??????????savepoint????????????????
&gt;&gt;
&gt;&gt;
&gt;&gt; CREATE TABLE A_source??...??
&gt;&gt; CREATE TABLE B_sink ??...??
&gt;&gt; CREATE TABLE C_source??...??
&gt;&gt; CREATE TABLE D_sink ??...??
&gt;&gt; INSERT INTO B_sink
&gt;&gt; SELECT
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 1
&gt;&gt; FROM
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp; A_source
&gt;&gt; ;
&gt;&gt;
&gt;&gt;
&gt;&gt; INSERT INTO C_sink
&gt;&gt; SELECT
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; 1
&gt;&gt; FROM
&gt;&gt;&nbsp;&nbsp;&nbsp;&nbsp; D_source
&gt;&gt; ;
&gt;&gt; ??????Savepoint??????????????
&gt;&gt;
&gt;&gt; Cannot map checkpoint/savepoint state for operator
&gt;&gt; 2e9c6b0c053878cef673bbe7d94ab037 to the new program, because the 
operator
&gt;&gt; is not available in the new program.
&gt;&gt; If you want to allow to skip this, you can set the
&gt;&gt; --allowNonRestoredState option on the CLI.
&gt;&gt;
&gt;&gt;
&gt;&gt; ??????????????????????????????????opertor??????????
&gt;
&gt;