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

kcz Tue, 09 Jun 2020 20:33:48 -0700

????tks????????




------------------&nbsp;????????&nbsp;------------------
??????:&nbsp;"Yichao Yang"<1048262...@qq.com&gt;;
????????:&nbsp;2020??6??10??(??????) ????11:32
??????:&nbsp;"user-zh"<user-zh@flink.apache.org&gt;;

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



Hi


Flink sql 
??????????????????????uid????????????sql??????????????????????datastream 
api????????


Best,
Yichao Yang




------------------&amp;nbsp;????????&amp;nbsp;------------------
??????:&amp;nbsp;"kcz"<573693...@qq.com&amp;gt;;
????????:&amp;nbsp;2020??6??10??(??????) ????11:27
??????:&amp;nbsp;"user-zh"<user-zh@flink.apache.org&amp;gt;;

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



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




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

????:&amp;amp;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&amp;amp;gt; ??2020??6??9?????? ????9:26??????

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

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

回复