使用Flink 1.20.0从Savepoint启动PyFlink作业失败，咨询正确启动方式

我之前也碰到过类似的问题，这个报错看起来是命令参数解析出了问题，导致Flink没正确识别这是一个PyFlink作业，进而提示模块缺失。结合你的情况，给你几个可行的解决思路：

• 调整作业参数的传递方式：你命令里的--table、--bucket这些属于你的Python作业自己的参数，需要和Flink的提交参数用--分隔开。Flink会把--后面的参数原封不动传递给你的脚本，不会当作自身的命令参数解析。正确的命令应该改成这样：

  flink run --fromSavepoint s3a://.../1a4e1e73910e5d953183b8eb1cd6eb84/chk-1 -py flink_job.py -pyFiles requirements.txt -- --table my_table --bucket my_bucket --secret my_secret
  

  这样调整后，Flink就能正确识别这是PyFlink作业，不会再报模块缺失的错误了。

• 确认Savepoint的兼容性：虽然你现在的问题出在提交阶段，但也要提前注意：要恢复的Savepoint必须是由同版本（Flink 1.20.0）的PyFlink作业生成的，而且作业的拓扑结构、算子ID不能有变更，不然就算提交成功，运行时也会出现状态恢复失败的问题。

• 检查flink-python模块完整性：既然不加--fromSavepoint能正常提交，说明模块本身是存在的，但可以再确认下Flink安装目录的lib文件夹里有没有flink-python-1.20.0.jar，确保文件没有损坏或者缺失。

备注：内容来源于stack exchange，提问作者Rinze