Hi ， 这种情况可能是你改变的 Flink SQL 的拓扑结构，导致部分算子的 uid 发生变化，然后在从状态恢复的时候，没有找到算子的状态。 所以在开发 SQL 任务的时候，一般更改 SQL 代码时，不要改变其拓扑结构,SQL 任务上线后，就不要在轻意改了。
Best, LakeShen 酷酷的浑蛋 <[email protected]> 于2020年4月2日周四 下午6:31写道： > 关键我的程序是flink-sql，其它的算子基本都设置过uid了，flink-sql可以设置uid吗，或者说sql中的自动分配的uid怎么查找呢 > > > | | > apache22 > | > | > [email protected] > | > 签名由网易邮箱大师定制 > 在2020年4月2日 18:22，Yangze Guo<[email protected]> 写道： > 如果没有显示指定的话，operator id将是一个随机生成的值[1]. > 当从savepoint恢复时，将依据这些id来匹配，如果发生了变化，可能是你修改了你的jobGraph。Flink推荐显示的指定operator > id字面量。[2] > > [1] > https://ci.apache.org/projects/flink/flink-docs-master/ops/state/savepoints.html#assigning-operator-ids > [2] > https://ci.apache.org/projects/flink/flink-docs-master/ops/state/savepoints.html#faq > > Best, > Yangze Guo > > On Thu, Apr 2, 2020 at 6:01 PM 酷酷的浑蛋 <[email protected]> wrote: > > > > Failed to rollback to checkpoint/savepoint > hdfs://xxx/savepoint-9d5b7a-66c0340f6672. Cannot map checkpoint/savepoint > state for operator cbc357ccb763df2852fee8c4fc7d55f2 to the new program, > because the operator is not available in the new program. If you want to > allow to skip this, you can set the --allowNonRestoredState option on the > CLI. > > > 像上面这个错误，我怎么根据 operator cbc357ccb763df2852fee8c4fc7d55f2 去找是我程序中的哪个算子不能恢复呢？ > | | > apache22 > | > | > [email protected] > | > 签名由网易邮箱大师定制 >
