如果没有显示指定的话，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] > | > 签名由网易邮箱大师定制
