Hi
Flink sql ??????????????????????uid????????????sql??????????????????????datastream api???????? Best, Yichao Yang ------------------ ???????? ------------------ ??????: "kcz"<573693...@qq.com>; ????????: 2020??6??10??(??????) ????11:27 ??????: "user-zh"<user-zh@flink.apache.org>; ????: ?????? ????FlinkSQL????operatoer??????savepoint?????????????? sql???????? operatorID??????????????????????????????????????????????????????????ID???????? ------------------&nbsp;????????&nbsp;------------------ ??????:&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;