关键我的程序是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] | 签名由网易邮箱大师定制
