Flink CDC有没有遇到过这种问题的？

问题1：Flink CDC有没有大佬遇到过这种问题的？StreamExecutionEnvironment模式下，如何配置allowNonRestoredState ？
Failed to rollback to checkpoint/savepoint hdfs://mycluster/flink-savepoints/savepoint-8be461-63c79a0260e8. Cannot map checkpoint/savepoint state for operator 7407891570dcdf3d6445976816f30a0c 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.
问题2：这样配置，但是flink session下，不知道咋个配置？
问题3；但是不用session模式的话，要部署在hadoop的服务器上，才能用yarn的环境哇